run python job with flink 1.7

Posted by Joshua Fan on
URL: http://deprecated-apache-flink-user-mailing-list-archive.369.s1.nabble.com/run-python-job-with-flink-1-7-tp27911.html

Hi all

When I run the python example in flink 1.7, it always got a excepthon.

The command is: ./bin/pyflink.sh ./examples/python/streaming/word_count.py

The return message is:

2019-05-17 11:43:22,900 INFO  org.apache.hadoop.yarn.client.RMProxy                         - Connecting to ResourceManager at data01.hj.shbt.qihoo.net/10.203.82.17:8832

Starting execution of program

Traceback (most recent call last):

  File "/tmp/flink_plan_0a1aed4b-4155-4cfa-b2ba-8083a4a61f6e/plan.py", line 21, in <module>

    from org.apache.flink.api.common.functions import FlatMapFunction

ImportError: No module named org.apache.flink.api.common.functions

Failed to run plan: Plan file caused an error. Check log-files for details.

The program didn't contain a Flink job. Perhaps you forgot to call execute() on the execution environment.

Can not find any help in google.

Appreciate your help very much.

Sincerely

Joshua