[
https://issues.apache.org/jira/browse/FLINK-34660?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17827117#comment-17827117
]
Ryan Skraba commented on FLINK-34660:
-------------------------------------
On Github Actions, this might still fail: If I read correctly, this was after
the fix was committed to master:
*
[https://github.com/apache/flink/actions/runs/8274402076/job/22639938749#step:10:8127]
(Java 21 1.20-SNAPSHOT)
{code:java}
Error: 02:41:58 02:41:58.807 [ERROR] Tests run: 32, Failures: 1, Errors: 0,
Skipped: 0, Time elapsed: 123.0 s <<< FAILURE! -- in
org.apache.flink.test.checkpointing.AutoRescalingITCase
Error: 02:41:58 02:41:58.807 [ERROR]
org.apache.flink.test.checkpointing.AutoRescalingITCase.testCheckpointRescalingInKeyedState[backend
= filesystem, buffersPerChannel = 2, useIngestDB = false] -- Time elapsed:
2.529 s <<< FAILURE!
Mar 14 02:41:58 java.lang.AssertionError: 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), (1,80000), (1,0),
(1,16000), (1,24000), (1,40000), (1,56000), (1,64000), (0,28000), (0,52000),
(0,68000), (1,18000), (1,26000), (1,34000), (1,42000), (1,58000), (0,6000),
(0,30000), (0,38000), (0,14000), (0,22000), (0,46000), (0,62000), (0,70000),
(1,4000), (1,20000), (1,36000), (1,44000)]>
Mar 14 02:41:58 at org.junit.Assert.fail(Assert.java:89)
Mar 14 02:41:58 at org.junit.Assert.failNotEquals(Assert.java:835)
Mar 14 02:41:58 at org.junit.Assert.assertEquals(Assert.java:120)
Mar 14 02:41:58 at org.junit.Assert.assertEquals(Assert.java:146)
Mar 14 02:41:58 at
org.apache.flink.test.checkpointing.AutoRescalingITCase.testCheckpointRescalingKeyedState(AutoRescalingITCase.java:312)
Mar 14 02:41:58 at
org.apache.flink.test.checkpointing.AutoRescalingITCase.testCheckpointRescalingInKeyedState(AutoRescalingITCase.java:208)
Mar 14 02:41:58 at
java.base/java.lang.reflect.Method.invoke(Method.java:580)
Mar 14 02:41:58 at
org.apache.flink.util.TestNameProvider$1.evaluate(TestNameProvider.java:45){code}
> 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)
