为什么Flink SocketTextStreamWordCount不起作用?


0

我已经建立了示例项目并构建了它。我可以按预期运行WordCount程序。但是当我运行SocketTextWordCount时,我没有得到任何结果。

    我通过nc发送数据( local主机:9999开两侧)

但我从没见过计数.打印()输出打印在任何地方,即使在终止nc会话之后。

编辑-当我改变它以打印结果到一个文本文件,没有问题。所以问题是计数.打印()无法正确地写入我正在运行示例的控制台的stdout。

1 答案


0

数据流在TaskManager进程外打印为标准。启动Flink实例( local或集群)时,TaskManager的标准输出被定向到Flink root目录的./log/目录中的一个.out文件中。所以您应该检查输出是否写入这些文件。

这种行为与 DataSet .print(),其中结果在JobManager上收集,发送到 client,并由 client打印。


我来回答

写文章

提问题

面试题