Rui Fan created FLINK-31588:
-------------------------------
Summary: The unaligned checkpoint type is wrong at subtask level
Key: FLINK-31588
URL: https://issues.apache.org/jira/browse/FLINK-31588
Project: Flink
Issue Type: Bug
Components: Runtime / Checkpointing
Affects Versions: 1.17.0, 1.16.0
Reporter: Rui Fan
Assignee: Rui Fan
Attachments: image-2023-03-23-18-45-01-535.png
FLINK-20488 supported show checkpoint type for each subtask, and it based on
received `CheckpointOptions` and it's right.
However, FLINK-27251 supported timeout aligned to unaligned checkpoint barrier
in the output buffers. It means the received `CheckpointOptions` can be
converted from aligned checkpoint to unaligned checkpoint.
So, the unaligned checkpoint type may be wrong at subtask level. For example,
as shown in the figure below, Unaligned checkpoint type is false, but it is
actually Unaligned checkpoint (persisted data > 0).
!image-2023-03-23-18-45-01-535.png|width=1879,height=797!
--
This message was sent by Atlassian Jira
(v8.20.10#820010)