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

Reducing synchronization in AsyncWaitOperator

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

    Details

      Description

      Currently, AsyncWaitOperator receives computed results from a user thread and puts it in StreamElementQueue. This queue is synchronized as the emitter thread pulls available elements in a blocking fashion. With the recent migration to mailbox model, these elements are then put into a letter to be outputted in the mailbox thread.

      If we directly send the results from the user thread to the mailbox, we can get rid of any synchronization as everything happens in the user thread. That will slim down the code heavily.

        Attachments

        Issue Links

          Activity

            People

            • Assignee:
              arvid Arvid Heise
              Reporter:
              arvid Arvid Heise

              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