Hi, Which version of pyflink are you using? I think the api you are using is not the pyflink since flink 1.9. For detailed usage of pyflink, you can refer to doc[1]
[1] https://ci.apache.org/projects/flink/flink-docs-release-1.11/dev/python/table_api_tutorial.html Best, Xingbo 大森林 <appleyu...@foxmail.com> 于2020年10月13日周二 下午8:23写道： > > My code is: > https://paste.ubuntu.com/p/KqpKwTw5zH/ > > > My step is: > $FLINK_HOME/bin/flink run -py /wordcount.py > the sentence"data.output()"has no output. > > > where am I wrong in above code? > > Thanks for your help >
