Step 1 of 4: Choose Issues

Cancel

T Patch Info Key Summary Assignee Reporter P Status Resolution Created Updated Due Development
Sub-task FLINK-14857

FLINK-12477 Deprecate checkpoint lock from the Operators API

Roman Khachatryan Roman Khachatryan Major Closed Fixed  
Sub-task FLINK-14156

FLINK-12477 Execute/run processing timer triggers taking into account operator level mailbox loops

Alex Alex Major Closed Fixed  
Sub-task FLINK-13955

FLINK-12477 Integrate ContinuousFileReaderOperator with StreamTask mailbox execution model

Roman Khachatryan Alex Major Closed Fixed  
Sub-task FLINK-13248

FLINK-12477 Enhance mailbox executor with yield-to-downstream functionality

Arvid Heise Stefan Richter Major Closed Fixed  
Sub-task FLINK-13013

FLINK-12477 Make sure that SingleInputGate can always request partitions

Piotr Nowojski Piotr Nowojski Critical Closed Fixed  
Sub-task FLINK-12958

FLINK-12477 Integrate AsyncWaitOperator with mailbox

Unassigned Stefan Richter Major Closed Fixed  
Sub-task FLINK-12804

FLINK-12477 Introduce mailbox-based ExecutorService

Stefan Richter Stefan Richter Major Closed Implemented  
Sub-task FLINK-12536

FLINK-12477 Make BufferOrEventSequence#getNext() non-blocking

Congxian Qiu Piotr Nowojski Major Closed Won't Fix  
Sub-task FLINK-12484

FLINK-12477 Drop unnecessary locking for code-paths that now use the mailbox

Roman Khachatryan Stefan Richter Major Closed Fixed  
Sub-task FLINK-12483

FLINK-12477 Support (legacy) SourceFunctions with mailbox

Stefan Richter Stefan Richter Major Closed Implemented  
Sub-task FLINK-12482

FLINK-12477 Make checkpoint trigger/notifyComplete run via the mailbox queue

Alex Stefan Richter Major Closed Fixed  
Sub-task FLINK-12481

FLINK-12477 Make processing time timer trigger run via the mailbox

Alex Stefan Richter Major Closed Fixed  
Sub-task FLINK-12480

FLINK-12477 Introduce mailbox to StreamTask main-loop

Stefan Richter Stefan Richter Major Closed Implemented  
Sub-task FLINK-12479

FLINK-12477 Make InputProcessors and StreamIterationHead non-blocking

Piotr Nowojski Stefan Richter Major Closed Fixed  
Sub-task FLINK-12478

FLINK-12477 Decompose monolithic run-loops in StreamTask implementations into step-wise calls

Stefan Richter Stefan Richter Major Closed Implemented  

Cancel