Flink Streaming Twitter示例不起作用

Question

我正在尝试运行官方示例，该示例展示了如何在Twitter中使用Apache Flink流：https://github.com/apache/flink/tree/master/flink-streaming-examples/src/main/java/org/apache/flink/streaming/examples/twitter

如果我没有提供properties.file的路径，将使用TwitterStreamData.java。有了“数据看起来像推文”就可以了。但是如果我想要接收真正的tweet(提供正确的属性文件)，执行就会停止并等待(没有抛出异常)。

在代码调试之后，我找到了执行停止并等待的地方：

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

程序运行到行

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

然后等待。

属性文件是正常的，因为我在另一个示例(没有apache flink的tweet流)中使用了它，并且它是有效的。

Answer 1

这是阿帕奇HttpClient 4.2的问题所在。在将HttpClient 4.2.6添加到项目的依赖项之后，程序员运行。同样的问题也在这里讨论：IOExcpetion while connecting to Twitter Streaming API with Apache Flink。我在那里找到了答案。