Uploaded image for project: 'Beam'
  1. Beam
  2. BEAM-9060

Flink suppresses stdout/stderr during JobGraph generation from JAR

Attach filesAttach ScreenshotVotersWatch issueWatchersCreate sub-taskLinkCloneUpdate Comment AuthorReplace String in CommentUpdate Comment VisibilityDelete Comments
    XMLWordPrintableJSON

    Details

    • Type: Bug
    • Status: Resolved
    • Priority: P2
    • Resolution: Fixed
    • Affects Version/s: None
    • Fix Version/s: 2.19.0
    • Component/s: runner-flink
    • Labels:
      None

      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.

        Attachments

        Issue Links

          Activity

            People

            • Assignee:
              mxm Maximilian Michels
              Reporter:
              mxm Maximilian Michels

              Dates

              • Created:
                Updated:
                Resolved:

                Time Tracking

                Estimated:
                Original Estimate - Not Specified
                Not Specified
                Remaining:
                Remaining Estimate - 0h
                0h
                Logged:
                Time Spent - 1h 20m
                1h 20m

                  Issue deployment