[jira] [Commented] (FLINK-1418) Make 'print()' output on the client command line, rather than on the task manager sysout
[
https://issues.apache.org/jira/browse/FLINK-1418?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14309101#comment-14309101
]
Stephan Ewen commented on FLINK-1418:
-
If we ever break it, we should do it now.
Make 'print()' output on the client command line, rather than on the task
manager sysout
Key: FLINK-1418
URL: https://issues.apache.org/jira/browse/FLINK-1418
Project: Flink
Issue Type: Improvement
Components: Java API
Affects Versions: 0.9
Reporter: Stephan Ewen
Right now, the {{print()}} command prints inside the data sinks where the
code runs. It should pull data back to the client and print it there.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
[jira] [Commented] (FLINK-1418) Make 'print()' output on the client command line, rather than on the task manager sysout
[
https://issues.apache.org/jira/browse/FLINK-1418?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14309085#comment-14309085
]
Chesnay Schepler commented on FLINK-1418:
-
is this not doable without breaking programs?
I'm thinking of something like this:
whenever a print sink is created, an accumulator is created that stores the
output. the name of the accumulator is stored in a list in the ExEnv.
within env.execute(), after everything else ran (as in, before we return the
JobExecutionResult), iterate through the accumulator entries stored and print
the outputs the contents.
Make 'print()' output on the client command line, rather than on the task
manager sysout
Key: FLINK-1418
URL: https://issues.apache.org/jira/browse/FLINK-1418
Project: Flink
Issue Type: Improvement
Components: Java API
Affects Versions: 0.9
Reporter: Stephan Ewen
Right now, the {{print()}} command prints inside the data sinks where the
code runs. It should pull data back to the client and print it there.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
[jira] [Commented] (FLINK-1418) Make 'print()' output on the client command line, rather than on the task manager sysout
[
https://issues.apache.org/jira/browse/FLINK-1418?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14282360#comment-14282360
]
Fabian Hueske commented on FLINK-1418:
--
I agree, printing to the TMs std-out is pretty pointless and doesn't help
anybody and local testing will not be affected.
However, this change should come with a big warning sign in the documentation
and JavaDocs because it might cause huge results being transferred to the
client.
Make 'print()' output on the client command line, rather than on the task
manager sysout
Key: FLINK-1418
URL: https://issues.apache.org/jira/browse/FLINK-1418
Project: Flink
Issue Type: Improvement
Components: Java API
Affects Versions: 0.9
Reporter: Stephan Ewen
Right now, the {{print()}} command prints inside the data sinks where the
code runs. It should pull data back to the client and print it there.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
