[ 
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)

Reply via email to