Flink Streaming Twitter示例不起作用


0

我正在尝试运行一个官方示例,演示如何将Apache Flink streaming与Twitter结合使用:

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

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

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

程序一直运行到行结束

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

等待。

属性文件是可以的,因为我在另一个示例(没有apacheflink的tweets流)中使用了它,而且它是有效的。

1 答案


0

这是Apaches HttpClient 4.2的问题。将HttpClient 4.2.6添加到项目的依赖项后,程序运行。同样的问题也在这里讨论:使用Apache Flink joinTwitter streamingAPI时的ioexpetion。我在那里找到了答案。


我来回答

写文章

提问题

面试题