apache-flink - 为什么 Flink SocketTextStreamWordCount 不起作用？

Question

我已经设置并构建了示例项目。我能够按预期运行 WordCount 程序。但是当我运行 SocketTextWordCount 时，我没有打印出任何结果。

• 我通过 nc 发送数据(双方的 localhost:9999)
• 在运行作业的 Web 控制台中，我可以看到正在发送/接收消息

但我从未在任何地方看到 counts.print() 输出打印出来，即使在终止 nc session 之后也是如此。

编辑 - 当我改变它以将结果打印到文本文件时，没问题。所以问题似乎是 counts.print() 没有正确写入我正在运行示例的控制台的标准输出。

Answer 1

DataStreams 被打印到 TaskManager 进程的标准输出。当启动 Flink 实例(本地或集群)时，TaskManager 的标准输出被定向到 Flink 根的 ./log/ 目录中的 .out 文件目录。所以你应该检查输出是否写入这些文件。

此行为不同于 DataSet.print()，后者的结果在 JobManager 上收集，传送到客户端，并由客户端打印。