[
https://issues.apache.org/jira/browse/FLINK-34660?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hangxiang Yu resolved FLINK-34660.
----------------------------------
Fix Version/s: 1.20.0
Assignee: Hangxiang Yu
Resolution: Fixed
merged aa71589 into master
> 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
> Assignee: Hangxiang Yu
> Priority: Major
> Labels: pull-request-available
> Fix For: 1.20.0
>
>
> [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)
