小编wil*_*red的帖子

为什么Flink SocketTextStreamWordCount不起作用?

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

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

但我从未看到在任何地方打印出的counts.print()输出,即使在杀死nc会话之后也是如此.

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

apache-flink flink-streaming

2
推荐指数
1
解决办法
633
查看次数

标签 统计

apache-flink ×1

flink-streaming ×1