Uploaded image for project: 'Flink'
  1. Flink
  2. FLINK-12477 Change threading-model in StreamTask to a mailbox-based approach
  3. FLINK-12481

Make processing time timer trigger run via the mailbox

    XMLWordPrintableJSON

Details

    Description

      This sub-task integrates the mailbox with processing time timer triggering. Those triggers should now be enqueued as mailbox events and picked up by the stream task's main thread for processing.

      Attachments

        Issue Links

          relates to

          Improvement - An improvement or enhancement to an existing feature or task. FLINK-9845 Make InternalTimerService's timer processing interruptible/abortable

          • Not a Priority -
          • Open
          links to

          Web Link GitHub Pull Request #8523

          Web Link GitHub Pull Request #9564

          Activity

            People

              1u0 Alex
              srichter Stefan Richter
              Votes:
              0 Vote for this issue
              Watchers:
              8 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved:

                Time Tracking

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