[
https://issues.apache.org/jira/browse/FLINK-39162?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rui Fan updated FLINK-39162:
----------------------------
Description:
When I am working on FLINK-39140 to improve the unaligned checkpoint ITCases, I
encountered a high frequency of test failures for the test case :
Topology.CUSTOM_PARTITIONER [1]
It could be reproduced reliably when upscale custom partitioner.
{code:java}
# existing CUSTOM_PARTITIONER test case
new Object[] {"downscale", Topology.CUSTOM_PARTITIONER, 3, 2, 0L},
# failure test case
new Object[] {"upscale", Topology.CUSTOM_PARTITIONER, 2, 3, 0L}, {code}
Do not know why the test case only covered downscaling and not upscaling.
[1]
[https://github.com/apache/flink/blob/9964ab4bd1b8334dec9388e1e4dac68c94488691/flink-tests/src/test/java/org/apache/flink/test/checkpointing/UnalignedCheckpointRescaleITCase.java#L552]
> The data of the custom partitioner is corrupted when unaligned checkpoint is
> enabled
> ------------------------------------------------------------------------------------
>
> Key: FLINK-39162
> URL: https://issues.apache.org/jira/browse/FLINK-39162
> Project: Flink
> Issue Type: Bug
> Components: Runtime / Checkpointing
> Reporter: Rui Fan
> Priority: Major
>
> When I am working on FLINK-39140 to improve the unaligned checkpoint ITCases,
> I encountered a high frequency of test failures for the test case :
> Topology.CUSTOM_PARTITIONER [1]
> It could be reproduced reliably when upscale custom partitioner.
> {code:java}
> # existing CUSTOM_PARTITIONER test case
> new Object[] {"downscale", Topology.CUSTOM_PARTITIONER, 3, 2, 0L},
> # failure test case
> new Object[] {"upscale", Topology.CUSTOM_PARTITIONER, 2, 3, 0L}, {code}
> Do not know why the test case only covered downscaling and not upscaling.
> [1]
> [https://github.com/apache/flink/blob/9964ab4bd1b8334dec9388e1e4dac68c94488691/flink-tests/src/test/java/org/apache/flink/test/checkpointing/UnalignedCheckpointRescaleITCase.java#L552]
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
