why this pyflink code has no output?

classic Classic list List threaded Threaded
2 messages Options
Reply | Threaded
Open this post in threaded view
|

why this pyflink code has no output?

大森林

My code is:


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
Reply | Threaded
Open this post in threaded view
|

Re: why this pyflink code has no output?

Xingbo Huang
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 

大森林 <[hidden email]> 于2020年10月13日周二 下午8:23写道:

My code is:


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