Uploaded image for project: 'Flink'
  1. Flink
  2. FLINK-16705

LocalExecutor tears down MiniCluster before client can retrieve JobResult

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

    Details

      Description

      There is a race condition in LocalExecutor between (a) shutting down the cluster when the job has finished and (b) the client which retrieves the result of the job execution.

      This was observed in Beam, running a large test suite with the Flink Runner.

      We should make sure the job result retrieval and the cluster shutdown do not interfere.

        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 - 20m
                20m

                  Issue deployment