[ https://issues.apache.org/jira/browse/FLINK-33959?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Rui Fan updated FLINK-33959: ---------------------------- 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 {code:java} 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 {code} was: [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] !image-2023-12-29-19-51-35-996.png! > Unstable test case > ------------------- > > Key: FLINK-33959 > URL: https://issues.apache.org/jira/browse/FLINK-33959 > Project: Flink > Issue Type: Bug > Components: Tests > Affects Versions: 1.17.0, 1.17.1, 1.17.2 > Reporter: RocMarshal > Priority: Blocker > Attachments: image-2023-12-29-19-51-35-996.png > > > [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 > > {code:java} > 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 > {code} > -- This message was sent by Atlassian Jira (v8.20.10#820010)