[FLINK-34200] AutoRescalingITCase#testCheckpointRescalingInKeyedState fails

• Type: Bug
• Status: Resolved
• Priority: Critical
• Resolution: Fixed
• Affects Version/s: 1.19.0
• Fix Version/s: 1.19.0, 1.20.0
• Component/s: Runtime / Checkpointing
• Labels: pull-request-available test-stability
• Assignee: Rui Fan
• Reporter: Matthias Pohl
• Created: 22/Jan/24 15:21
• Updated: 08/Feb/24 16:30
• Resolved: 08/Feb/24 16:30

Description

https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=56601&view=logs&j=8fd9202e-fd17-5b26-353c-ac1ff76c8f28&t=ea7cf968-e585-52cb-e0fc-f48de023a7ca&l=8200

Jan 19 02:31:53 02:31:53.954 [ERROR] Tests run: 32, Failures: 1, Errors: 0, Skipped: 0, Time elapsed: 1050 s <<< FAILURE! -- in org.apache.flink.test.checkpointing.AutoRescalingITCase
Jan 19 02:31:53 02:31:53.954 [ERROR] org.apache.flink.test.checkpointing.AutoRescalingITCase.testCheckpointRescalingInKeyedState[backend = rocksdb, buffersPerChannel = 2] -- Time elapsed: 59.10 s <<< FAILURE!
Jan 19 02:31:53 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,12000), (0,28000), (0,52000), (0,60000), (0,68000), (0,76000), (0,1000), (0,25000), (0,33000), (0,41000), (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)]>
Jan 19 02:31:53 	at org.junit.Assert.fail(Assert.java:89)
Jan 19 02:31:53 	at org.junit.Assert.failNotEquals(Assert.java:835)
Jan 19 02:31:53 	at org.junit.Assert.assertEquals(Assert.java:120)
Jan 19 02:31:53 	at org.junit.Assert.assertEquals(Assert.java:146)
Jan 19 02:31:53 	at org.apache.flink.test.checkpointing.AutoRescalingITCase.testCheckpointRescalingKeyedState(AutoRescalingITCase.java:296)
Jan 19 02:31:53 	at org.apache.flink.test.checkpointing.AutoRescalingITCase.testCheckpointRescalingInKeyedState(AutoRescalingITCase.java:196)
Jan 19 02:31:53 	at java.lang.reflect.Method.invoke(Method.java:498)
Jan 19 02:31:53 	at org.apache.flink.util.TestNameProvider$1.evaluate(TestNameProvider.java:45) 

Issue Links

• is caused by: FLINK-33246 Add RescalingIT case that uses checkpoints and resource requests
• is duplicated by: FLINK-34218 AutoRescalingITCase#testCheckpointRescalingInKeyedState fails
• is related to: FLINK-33919 AutoRescalingITCase hangs on AZP
• links to: GitHub Pull Request #24246
• links to: GitHub Pull Request #24286