[
https://issues.apache.org/jira/browse/FLINK-377?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14314382#comment-14314382
]
ASF GitHub Bot commented on FLINK-377:
--------------------------------------
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
> Create a general purpose framework for language bindings
> --------------------------------------------------------
>
> Key: FLINK-377
> URL: https://issues.apache.org/jira/browse/FLINK-377
> Project: Flink
> Issue Type: Improvement
> Reporter: GitHub Import
> Assignee: Chesnay Schepler
> Labels: github-import
> Fix For: pre-apache
>
>
> A general purpose API to run operators with arbitrary binaries.
> This will allow to run Stratosphere programs written in Python, JavaScript,
> Ruby, Go or whatever you like.
> We suggest using Google Protocol Buffers for data serialization. This is the
> list of languages that currently support ProtoBuf:
> https://code.google.com/p/protobuf/wiki/ThirdPartyAddOns
> Very early prototype with python:
> https://github.com/rmetzger/scratch/tree/learn-protobuf (basically testing
> protobuf)
> For Ruby: https://github.com/infochimps-labs/wukong
> Two new students working at Stratosphere (@skunert and @filiphaase) are
> working on this.
> The reference binding language will be for Python, but other bindings are
> very welcome.
> The best name for this so far is "stratosphere-lang-bindings".
> I created this issue to track the progress (and give everybody a chance to
> comment on this)
> ---------------- Imported from GitHub ----------------
> Url: https://github.com/stratosphere/stratosphere/issues/377
> Created by: [rmetzger|https://github.com/rmetzger]
> Labels: enhancement,
> Assignee: [filiphaase|https://github.com/filiphaase]
> Created at: Tue Jan 07 19:47:20 CET 2014
> State: open
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
