私は最近、実験的からベータ版に移行したTone AnalyzerのAPIの変更を処理するチュートリアルを更新しました。チュートリアルの最新バージョンを使用していますか?
なぜあなたがつぶやきを受け取っていないのかを説明する複数の理由があります:誤ったツイッターまたはトーンアナライザーの資格情報。チュートリアルの指示に従ってこれらを再度確認してください。エラーをより正確に診断するために、最新のチュートリアルバージョンにStreamingListenerを追加しました。これにより、より多くの情報を得ることができます。あなたは次のようにメッセージが表示されます。あなたは私がGitHubのに掲示事前に構築されたjarファイルを使用している場合
Twitter stream started
Tweets are collected real-time and analyzed
To stop the streaming and start interacting with the data use: StreamingTwitter.stopTwitterStreaming
Receiver Started: TwitterReceiver-0
Batch started with 139 records
Batch completed with 139 records
Batch started with 270 records
Stopping Twitter stream. Please wait this may take a while
Receiver Stopped: TwitterReceiver-0
Reason: : Stopped by driver
Batch completed with 270 records
Twitter stream stopped
You can now create a sqlContext and DataFrame with 38 Tweets created. Sample usage:
val (sqlContext, df) = com.ibm.cds.spark.samples.StreamingTwitter.createTwitterDataFrames(sc)
df.printSchema
sqlContext.sql("select author, text from tweets").show
最後に、あなたがスパーク1.6とないバックレベルのバージョンを使用していることを確認してください。
ありがとうMr.Taieb。私はこのチュートリアルの古いバージョンで作業していました。私は今、新しいバージョンを使用し、それは完全に動作します。私は別の質問がありますが、私は別の投稿に別々に書きますので、他の人にも役立ちます。 – fano