wil*_*red 2 apache-flink flink-streaming
我已经设置了示例项目并构建了它.我能按预期运行WordCount程序.但是当我运行SocketTextWordCount时,我没有打印出任何结果.
但我从未看到在任何地方打印出的counts.print()输出,即使在杀死nc会话之后也是如此.
编辑 - 当我改变它以将结果打印到文本文件时,没问题.所以问题似乎是count.print()没有正确写入我正在运行示例的控制台的stdout.
DataStreams打印到TaskManager进程的标准输出.启动Flink实例(本地或集群)时,TaskManager的标准输出将被定向到Flink根目录.out的./log/目录中的文件中.所以你应该检查输出是否写入这些文件.
此行为不同于DataSet.print(),结果在JobManager上收集,发送到客户端,并由客户端打印.
| 归档时间： |
|
| 查看次数： |
633 次 |
| 最近记录： |