我正在尝试运行一个官方示例，演示如何将apache flink流媒体与twitter结合使用：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);

等待。
属性文件是可以的，因为我在另一个示例（没有apacheflink的tweets流）中使用了它，而且它是有效的。