[FLINK-33959] Unstable test case ChangelogRecoveryITCase.testMaterialization on 1.17 release branch

• Type: Bug
• Status: Closed
• Priority: Blocker
• Resolution: Duplicate
• Affects Version/s: 1.17.0, 1.17.1, 1.17.2
• Component/s: Tests
• Assignee: Unassigned
• Reporter: RocMarshal
• Created: 29/Dec/23 11:50
• Updated: 02/Jan/24 10:04
• Resolved: 02/Jan/24 09:44

Description

https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=55940&view=logs&j=a57e0635-3fad-5b08-57c7-a4142d7d6fa9&t=2ef0effc-1da1-50e5-c2bd-aab434b1c5b7

 
Dec 29 07:35:05 [ERROR] ChangelogRecoveryITCase.testMaterialization
Dec 29 07:35:05 [INFO] Run 1: PASS
Dec 29 07:35:05 [ERROR] Run 2: org.apache.flink.runtime.JobException: Recovery is suppressed by FixedDelayRestartBackoffTimeStrategy(maxNumberRestartAttempts=2, backoffTimeMS=0)
 
Dec 29 07:35:05 [INFO] Run 3: PASS

 

Dec 29 07:31:37 Caused by: java.io.FileNotFoundException: /tmp/junit666440189967214661/junit7847292894745938127/7c8c2cdf87500be80d28b1001902edcc/dstl/3cc55f1f-bd4f-4bc6-a41d-e8d91b54b4b0 (No such file or directory)
Dec 29 07:31:37 	at java.io.FileInputStream.open0(Native Method)
Dec 29 07:31:37 	at java.io.FileInputStream.open(FileInputStream.java:195)
Dec 29 07:31:37 	at java.io.FileInputStream.<init>(FileInputStream.java:138)
Dec 29 07:31:37 	at org.apache.flink.core.fs.local.LocalDataInputStream.<init>(LocalDataInputStream.java:50)
Dec 29 07:31:37 	at org.apache.flink.core.fs.local.LocalFileSystem.open(LocalFileSystem.java:134)
Dec 29 07:31:37 	at org.apache.flink.core.fs.SafetyNetWrapperFileSystem.open(SafetyNetWrapperFileSystem.java:87)
Dec 29 07:31:37 	at org.apache.flink.runtime.state.filesystem.FileStateHandle.openInputStream(FileStateHandle.java:69)
Dec 29 07:31:37 	at org.apache.flink.changelog.fs.ChangelogStreamHandleReaderWithCache.openAndSeek(ChangelogStreamHandleReaderWithCache.java:89)
Dec 29 07:31:37 	at org.apache.flink.changelog.fs.StateChangeIteratorImpl.read(StateChangeIteratorImpl.java:42)
Dec 29 07:31:37 	at org.apache.flink.runtime.state.changelog.StateChangelogHandleStreamHandleReader$1.advance(StateChangelogHandleStreamHandleReader.java:85)
Dec 29 07:31:37 	... 21 more
 

 

Issue Links

• is fixed by: FLINK-28440 EventTimeWindowCheckpointingITCase failed with restore