求问我的pyflink wordcount为何没有任何输出?谢谢

classic Classic list List threaded Threaded
1 message Options
Reply | Threaded
Open this post in threaded view
|

求问我的pyflink wordcount为何没有任何输出?谢谢

大森林
完整代码是:
https://paste.ubuntu.com/p/KqpKwTw5zH/




运行步骤是:
$FLINK_HOME/bin/flink run -py /wordcount.py
data.output()没有任何输出
请问代码哪里错了,谢谢!