Hi All, I'm trying to use Flink with the python API, and started with the wordcount exemple <https://ci.apache.org/projects/flink/flink-docs-release-1.4/dev/batch/python.html#example-program> from the Documentation. I'm using Flink 1.4 and python 2.7. When running env.execute(local=True), the command doesn't execute and keeps waiting for input. If I hit enter again I get the following error from Environment.py : ValueError("Invalid mode specified: " + mode) Looking at the source code <https://github.com/apache/flink/blob/master/flink-libraries/flink-python/src/main/python/org/apache/flink/python/api/flink/plan/Environment.py>, it looks like there are a bunch of sys.stdin.readline().rstrip('\n') where an input is expected from the user. Any idea how to run the job? Thank you.
Best, Yassine
