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
