Flink 流式 Twitter 示例不起作用答案

【问题标题】：Flink Streaming Twitter Example doesn't workFlink 流式 Twitter 示例不起作用
【发布时间】：2015-12-14 15:43:22
【问题描述】：

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

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

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

程序一直运行到行

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

然后等待。

属性文件没问题，因为我在另一个示例中使用了它（没有 apache flink 的推文流式传输）并且有效。

【问题讨论】：

我假设您从 IDE 执行作业？你能看到任何日志输出吗？
您的问题似乎与stackoverflow.com/a/33157689/4815083 重复。它是由错误的 httpClient 版本引起的。我会在master中更新版本。
是的，谢谢，我在几个小时前找到了这个问题的解决方案。
IOExcpetion while connecting to Twitter Streaming API with Apache Flink的可能重复

【解决方案1】：

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

【讨论】：