You are viewing a plain text version of this content. The canonical link for it is here.

Posted to issues@beam.apache.org by "Maximilian Michels (Jira)" <ji...@apache.org> on 2020/01/07 15:48:00 UTC

[jira] [Created] (BEAM-9060) Flink suppresses stdout/stderr during JobGraph generation from JAR

Maximilian Michels created BEAM-9060:
----------------------------------------

             Summary: Flink suppresses stdout/stderr during JobGraph generation from JAR
                 Key: BEAM-9060
                 URL: https://issues.apache.org/jira/browse/BEAM-9060
             Project: Beam
          Issue Type: Bug
          Components: runner-flink
            Reporter: Maximilian Michels
            Assignee: Maximilian Michels


Flink uses the {{OptimizedPlanEnvironment}} which replaces stdout/stderr during job graph creation. This was intended only for previewing the plan, but other parts of Flink, e.g. the Rest API have started to use this code as well. 

We can work around FLINK-15504 by restoring the original stdout/stderr when we detect the {{OptimizedPlanEnvironment}}.



--
This message was sent by Atlassian Jira
(v8.3.4#803005)