[BEAM-9060] Flink suppresses stdout/stderr during JobGraph generation from JAR

• Type: Bug
• Status: Resolved
• Priority: P2
• Resolution: Fixed
• Fix Version/s: 2.19.0
• Component/s: runner-flink
• Assignee: Maximilian Michels
• Reporter: Maximilian Michels
• Created: 07/Jan/20 15:47
• Updated: 16/May/20 14:15
• Resolved: 08/Jan/20 21:27

Description

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.

Issue Links

• is caused by: FLINK-15504 Flink suppresses stdout/stderr during JobGraph generation from JAR
• links to: GitHub Pull Request #10517