Bulk Operation

  1. Choose Issues
  2. Choose Operation
  3. Operation Details
  4. Confirmation

Step 1 of 4: Choose Issues

Cancel

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

FLINK-14551 Update documentation taking unaligned checkpoints into the account

Arvid Heise Piotr Nowojski Critical Closed Fixed  
Sub-task FLINK-17873

FLINK-14551 Add check for max concurrent checkpoints under UC mode

Yuan Mei Yuan Mei Major Closed Fixed  
Sub-task FLINK-17719

FLINK-14551 Provide ChannelStateReader#hasStates for hints of reading channel states

Zhijiang Zhijiang Major Closed Fixed  
Sub-task FLINK-17547

FLINK-14551 Support unaligned checkpoints for records spilled to files

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

FLINK-14551 Implement aligned savepoint in UC mode

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

FLINK-14551 Refactor the usages of ThreadSafeUnaligner#storeNewBuffers

Zhijiang Zhijiang Major Closed Duplicate  
Sub-task FLINK-17342

FLINK-14551 Schedule savepoint if max-inflight-checkpoints limit is reached instead of forcing (in UC mode)

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

FLINK-14551 Enable unaligned checkpoints in tests by default

Arvid Heise Arvid Heise Major Closed Fixed  
Sub-task FLINK-17218

FLINK-14551 Add recovery to integration tests of unaligned checkpoints

Arvid Heise Arvid Heise Major Closed Fixed  
Sub-task FLINK-17156

FLINK-14551 Add checkpoint cancellation to Unaligner

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

FLINK-14551 Persist spilled records of SpillingAdaptiveSpanningRecordDeserializer

Roman Khachatryan Piotr Nowojski Critical Closed Duplicate  
Sub-task FLINK-16744

FLINK-14551 Implement API to persist channel state

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

FLINK-14551 Add basic CheckpointBarrierHandler for unaligned checkpoint

Arvid Heise Arvid Heise Major Closed Fixed  
Sub-task FLINK-16586

FLINK-14551 Build ResultSubpartitionInfo and InputChannelInfo in respective constructors

Zhijiang Zhijiang Major Closed Fixed  
Sub-task FLINK-16537

FLINK-14551 Implement ResultPartition state recovery for unaligned checkpoint

Zhijiang Zhijiang Major Closed Fixed  
Sub-task FLINK-16536

FLINK-14551 Implement InputChannel state recovery for unaligned checkpoint

Zhijiang Zhijiang Major Closed Fixed  
Sub-task FLINK-16513

FLINK-14551 Implement API to persist channel state: checkpointing metadata

Roman Khachatryan Roman Khachatryan Major Closed Implemented  
Sub-task FLINK-16512

FLINK-14551 Add API to persist channel state

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

FLINK-14551 Respect non-blocking output in StreamTask#processInput

Zhijiang Zhijiang Minor Closed Fixed  
Sub-task FLINK-14498

FLINK-14551 Introduce NetworkBufferPool#isAvailable() for non-blocking output

Yingjie Cao Zhijiang Minor Closed Fixed  
Sub-task FLINK-14472

FLINK-14551 Implement back-pressure monitor with non-blocking outputs

Yingjie Cao Zhijiang Minor Closed Fixed  
Sub-task FLINK-14396

FLINK-14551 Implement rudimentary non-blocking network output

Zhijiang Zhijiang Minor Closed Fixed  
Sub-task FLINK-14394

FLINK-14551 Remove unnecessary interface method BufferProvider#requestBufferBlocking

Zhijiang Zhijiang Minor Closed Fixed  

Cancel