Rui Fan created FLINK-33693:
-------------------------------
Summary: The disable unaligned checkpoint isn't respected when the
aligned checkpoint timeout is enabled
Key: FLINK-33693
URL: https://issues.apache.org/jira/browse/FLINK-33693
Project: Flink
Issue Type: Bug
Components: Runtime / Checkpointing
Affects Versions: 1.17.2, 1.18.0
Reporter: Rui Fan
Assignee: Rui Fan
Attachments: image-2023-11-29-20-41-17-038.png
The disable unaligned checkpoint isn't respected when the aligned checkpoint
timeout is enabled.
Bug at org.apache.flink.streaming.runtime.io.RecordWriterOutput#broadcastEvent,
we will call withUnalignedUnsupported to transmit the unaligned checkpoint
barrier to {color:#9876aa}FORCED_ALIGNED {color}barrier when the shuffle type
cannot use unaligned checkpoint.
However, the if has one condition: isPriorityEvent. When aligned checkpoint
timeout is enabled, flink will emit one timeoutable barrier. It isn't
PriorityEvent.
But timeoutable barrier should call withUnalignedUnsupported here.
!image-2023-11-29-20-41-17-038.png!
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
