1

Twitter で Apache Flink ストリーミングを使用する方法を示す公式の例を実行しようとしています: https://github.com/apache/flink/tree/master/flink-streaming-examples/src/main/java/org/apache /フリンク/ストリーミング/例/ツイッター

properties.file へのパスを指定しない場合、TwitterStreamData.java が使用されます。「つぶやきみたいなデータ」でOKです。しかし、(正しいプロパティ ファイルを提供して) 実際のツイートを受信したい場合は、実行が停止して待機します (例外はスローされません)。

コードのデバッグ後、実行が停止して待機する場所を見つけました。

ClusterUtils.runOnMiniCluster(obGraph jobGraph, int parallelism, long memorySize, boolean printDuringExecution)

プログラムは行まで実行されます

SerializedJobExecutionResult result = exec.submitJobAndWait(jobGraph, printDuringExecution);

そして待っています。

他の例 (apache flink を使用しないツイートのストリーミング) で使用したため、プロパティ ファイルは問題ありません。

4

1 に答える 1

1

Apaches HttpClient 4.2 の問題でした。プロジェクトの依存関係に HttpClient 4.2.6 を追加すると、プログラムが実行されます。同じ問題がここで議論されています: Apache Flink で Twitter Streaming API に接続している間の IOExcpetion。そこに答えを見つけました。

于 2015-12-15T15:26:08.197 に答える