You are viewing a plain text version of this content. The canonical link for it is here.

Posted to issues@flink.apache.org by "Stefan Richter (JIRA)" <ji...@apache.org> on 2019/05/23 07:46:00 UTC

[jira] [Closed] (FLINK-12480) Introduce mailbox to StreamTask main-loop

     [ https://issues.apache.org/jira/browse/FLINK-12480?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Stefan Richter closed FLINK-12480.
----------------------------------
    Resolution: Implemented

Merged in:
master 022f6cce

> Introduce mailbox to StreamTask main-loop
> -----------------------------------------
>
>                 Key: FLINK-12480
>                 URL: https://issues.apache.org/jira/browse/FLINK-12480
>             Project: Flink
>          Issue Type: Sub-task
>          Components: Runtime / Operators
>            Reporter: Stefan Richter
>            Assignee: Stefan Richter
>            Priority: Major
>              Labels: pull-request-available
>          Time Spent: 20m
>  Remaining Estimate: 0h
>
> In this sub-task, we introduce the mailbox data-structure to the {{StreamTask}}'s main-loop that runs the step-wise actions. After this sub-task, the mailbox events should already be respected, but the loop will currently still always find that the mailbox is empty because it is not yet integrated with the events that we will include in the next sub-tasks.



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)