|
|
|
FLINK-19801
|
FLINK-19442
Add support for virtual channels
|
Arvid Heise
|
Arvid Heise
|
|
Resolved |
Fixed
|
|
|
|
|
|
|
|
FLINK-19682
|
FLINK-19442
Actively timeout checkpoint barriers on the inputs
|
Dawid Wysakowicz
|
Piotr Nowojski
|
|
Closed |
Fixed
|
|
|
|
|
|
|
|
FLINK-19681
|
FLINK-19442
Passively timeout alignment on the inputs
|
Piotr Nowojski
|
Piotr Nowojski
|
|
Closed |
Fixed
|
|
|
|
|
|
|
|
FLINK-19680
|
FLINK-19442
Add EventAnnouncement priority message
|
Piotr Nowojski
|
Piotr Nowojski
|
|
Closed |
Fixed
|
|
|
|
|
|
|
|
FLINK-19679
|
FLINK-19442
Deduplicate code between CheckpointBarrierUnaligner and CheckpointBarrierAligner
|
Piotr Nowojski
|
Piotr Nowojski
|
|
Closed |
Fixed
|
|
|
|
|
|
|
|
FLINK-19533
|
FLINK-19442
Add state assignment to channel state during rescaling
|
Arvid Heise
|
Arvid Heise
|
|
Resolved |
Fixed
|
|
|
|
|
|
|
|
FLINK-19385
|
FLINK-19442
Channel recovery may deadlock
|
Roman Khachatryan
|
Roman Khachatryan
|
|
Closed |
Duplicate
|
|
|
|
|
|
|
|
FLINK-19026
|
FLINK-19442
Improve threading model of Unaligner
|
Arvid Heise
|
Arvid Heise
|
|
Resolved |
Fixed
|
|
|
|
|
|
|
|
FLINK-18990
|
FLINK-19442
Optimize reading of channel state on recovery
|
Roman Khachatryan
|
Roman Khachatryan
|
|
Resolved |
Fixed
|
|
|
|
|
|
|
|
FLINK-18851
|
FLINK-19442
Add checkpoint type to checkpoint history entries in Web UI
|
goutham
|
Arvid Heise
|
|
Closed |
Fixed
|
|
|
|
|
|
|
|
FLINK-18694
|
FLINK-19442
Add unaligned checkpoint config to web ui
|
Kboh
|
Kboh
|
|
Closed |
Fixed
|
|
|
|
|
|
|
|
FLINK-17979
|
FLINK-19442
Support rescaling for Unaligned Checkpoints
|
Unassigned
|
Roman Khachatryan
|
|
Resolved |
Fixed
|
|
|
|
|
|
|
|
FLINK-17741
|
FLINK-19442
Create integration or e2e test for out of order (savepoint) barriers
|
Unassigned
|
Roman Khachatryan
|
|
Closed |
Abandoned
|
|
|
|
|
|
|
|
FLINK-16972
|
FLINK-19442
Fix non-blocking output availability logic.
|
Arvid Heise
|
Arvid Heise
|
|
Closed |
Fixed
|
|
|
|
|