[ https://issues.apache.org/jira/browse/FLINK-12482?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Alex reassigned FLINK-12482: ---------------------------- Assignee: Alex (was: Stefan Richter) > Make checkpoint trigger/notifyComplete run via the mailbox queue > ---------------------------------------------------------------- > > Key: FLINK-12482 > URL: https://issues.apache.org/jira/browse/FLINK-12482 > Project: Flink > Issue Type: Sub-task > Components: Runtime / Operators > Reporter: Stefan Richter > Assignee: Alex > Priority: Major > > For the stream source, we also need to enqueue checkpoint related signals > (trigger, notifyComplete) to the mailbox now so that they run in the stream > task's main-thread. -- This message was sent by Atlassian JIRA (v7.6.3#76005)