我已经建立了一个示例项目并构建了它。我可以按预期运行wordcount程序。但是当我运行sockettextwordcount时，我没有得到任何打印出来的结果。
我通过nc发送数据(localhost:9999 on （两侧）
在运行作业的web控制台中，我可以看到正在发送/接收消息
但是我从来没有看到counts.print（）输出输出输出到任何地方，即使在结束nc会话之后。
编辑-当我改变它周围打印结果到一个文本文件，没有问题。所以问题似乎是counts.print（）没有正确地写入我运行示例的控制台的标准输出。
1条答案
按热度按时间dgjrabp21#
数据流从taskmanager进程打印到标准。在启动flink示例（本地或集群）时，taskmanager的标准输出被定向到
.out文件在./log/flink根目录的目录。因此，您应该检查输出是否写入这些文件。这种行为不同于
DataSet.print()，其中结果在jobmanager上收集、发送到客户机并由客户机打印。