flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Joshua Fan <joshuafat...@gmail.com>
Subject run python job with flink 1.7
Date Fri, 17 May 2019 03:47:03 GMT
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

Mime
View raw message