flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From mxm <...@git.apache.org>
Subject [GitHub] flink pull request: [FLINK-377] [FLINK-671] Generic Interface / PA...
Date Tue, 10 Feb 2015 16:06:01 GMT
Github user mxm commented on the pull request:

    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
    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 infrastructure@apache.org or file a JIRA ticket
with INFRA.

View raw message