Flink流媒体Twitter示例不起作用

Question

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

如果我不提供到属性的路径。文件，推特流数据。将使用java。有了“数据看起来像推特”就没问题了。但如果我想接收真正的推文（提供正确的属性文件），执行会停止并等待（不会引发异常）。

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

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

程序一直运行到行结束

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

然后等待。

这个属性文件还可以，因为我在另一个示例中使用了它（在没有apache flink的情况下流式发送推文），这很有效。

Answer 1

这是Apache HttpClient 4.2的问题。将HttpClient 4.2.6添加到程序运行的项目的依赖项后。这里讨论了同样的问题：使用Apache Flink连接到Twitter Streaming API时的IOExcpetion。我在那里找到了答案。