Github user mxm commented on the pull request:
https://github.com/apache/flink/pull/202#issuecomment-73726322
With the current version of the pull request, I get the following when
executing
/pyflink2.sh ../resources/python/flink/example/WordCount.py
>Job execution switched to status RUNNING.
DataSource (ValueSource)(1/1) switched to SCHEDULED
DataSource (ValueSource)(1/1) switched to DEPLOYING
DataSource (ValueSource)(1/1) switched to RUNNING
MapPartition (PythonFlatMap -> PythonCombine)(1/1) switched to SCHEDULED
>MapPartition (PythonFlatMap -> PythonCombine)(1/1) switched to DEPLOYING
>DataSource (ValueSource)(1/1) switched to FINISHED
>MapPartition (PythonFlatMap -> PythonCombine)(1/1) switched to RUNNING
This hangs forever. If I abort, no Exception is thrown. The job manager log
states:
>org.apache.flink.runtime.jobmanager.JobManager$$anonfun$main$1$$anon$1 -
Received job 920dca962d0ba21e3be8d3997c0940f1 (Flink Java Job at Tue Feb 10
16:54:56 CET 2015).
org.apache.flink.runtime.jobmanager.JobManager$$anonfun$main$1$$anon$1 -
Scheduling job Flink Java Job at Tue Feb 10 16:54:56 CET 2015.
org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying
DataSource (ValueSource) (1/1) (attempt #0) to localhost
org.apache.flink.runtime.jobmanager.JobManager$$anonfun$main$1$$anon$1 -
Status of job 920dca962d0ba21e3be8d3997c0940f1 (Flink Java Job at Tue Feb 10
16:54:56 CET 2015) changed to RUNNING.
org.apache.flink.runtime.taskmanager.TaskManager - There is no
profiling enabled for the task manager.
org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying
MapPartition (PythonFlatMap -> PythonCombine) (1/1) (attempt #0) to localhost
org.apache.flink.runtime.taskmanager.Task - DataSource
(ValueSource) (1/1) switched to FINISHED
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at infrastruct...@apache.org or file a JIRA ticket
with INFRA.
---
