Hangxiang Yu created FLINK-34660:
------------------------------------
Summary: AutoRescalingITCase#testCheckpointRescalingInKeyedState
AssertionError
Key: FLINK-34660
URL: https://issues.apache.org/jira/browse/FLINK-34660
Project: Flink
Issue Type: Bug
Components: Runtime / Checkpointing
Reporter: Hangxiang Yu
[https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=58249&view=ms.vss-test-web.build-test-results-tab&runId=4036370&resultId=100718&paneView=debug]
{code:java}
expected:<[(0,8000), (0,32000), (0,48000), (0,72000), (1,78000), (1,30000),
(1,54000), (0,2000), (0,10000), (0,50000), (0,66000), (0,74000), (0,82000),
(1,80000), (1,0), (1,16000), (1,24000), (1,40000), (1,56000), (1,64000),
(0,12000), (0,28000), (0,52000), (0,60000), (0,68000), (0,76000), (1,18000),
(1,26000), (1,34000), (1,42000), (1,58000), (0,6000), (0,14000), (0,22000),
(0,38000), (0,46000), (0,62000), (0,70000), (1,4000), (1,20000), (1,36000),
(1,44000)]> but was:<[(0,8000), (0,32000), (0,48000), (0,72000), (1,78000),
(1,30000), (1,54000), (0,2000), (0,10000), (0,50000), (0,66000), (0,74000),
(0,82000), (0,23000), (0,31000), (1,80000), (1,0), (1,16000), (1,24000),
(1,40000), (1,56000), (1,64000), (0,12000), (0,28000), (0,52000), (0,60000),
(0,68000), (0,76000), (1,18000), (1,26000), (1,34000), (1,42000), (1,58000),
(0,6000), (0,14000), (0,22000), (0,19000), (0,35000), (1,4000), (1,20000),
(1,36000), (1,44000)]> {code}
This maybe related to FLINK-34624 as we could see from the log:
{code:java}
03:31:02,073 [ main] INFO
org.apache.flink.runtime.testutils.PseudoRandomValueSelector [] - Randomly
selected true for state.changelog.enabled
03:31:02,163 [jobmanager-io-thread-2] INFO
org.apache.flink.state.changelog.AbstractChangelogStateBackend [] -
ChangelogStateBackend is used, delegating EmbeddedRocksDBStateBackend. {code}
FLINK-34624 disables changelog since it doesn't support local rescaling
currently.
Even if disabling changelog for AutoRescalingITCase manually,
randomization may still be applied to it.
We should apply randomization only when it's not pre-defined.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
