You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "Hangxiang Yu (Jira)" <ji...@apache.org> on 2022/11/21 09:15:00 UTC
[jira] [Commented] (FLINK-30107) Unstable test ChangelogRecoveryITCase#testMaterialization failed on azure
[ https://issues.apache.org/jira/browse/FLINK-30107?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17636572#comment-17636572 ]
Hangxiang Yu commented on FLINK-30107:
--------------------------------------
Caused by: java.lang.RuntimeException: java.io.FileNotFoundException: /tmp/junit7849331111491208454/junit6019736675453245587/8e0bcf531bdfb49f9cc23855d307e0ea/dstl/aee1f583-55a5-4f33-88ba-b50a5bd86386 (No such file or directory)
Nov 18 06:00:11 at org.apache.flink.util.ExceptionUtils.rethrow(ExceptionUtils.java:321)
Nov 18 06:00:11 at org.apache.flink.runtime.state.changelog.StateChangelogHandleStreamHandleReader$1.advance(StateChangelogHandleStreamHandleReader.java:87)
Nov 18 06:00:11 at org.apache.flink.runtime.state.changelog.StateChangelogHandleStreamHandleReader$1.hasNext(StateChangelogHandleStreamHandleReader.java:69)
Nov 18 06:00:11 at org.apache.flink.state.changelog.restore.ChangelogBackendRestoreOperation.readBackendHandle(ChangelogBackendRestoreOperation.java:107)
Nov 18 06:00:11 at org.apache.flink.state.changelog.restore.ChangelogBackendRestoreOperation.restore(ChangelogBackendRestoreOperation.java:78)
Nov 18 06:00:11 at org.apache.flink.state.changelog.ChangelogStateBackend.restore(ChangelogStateBackend.java:94)
Nov 18 06:00:11 at org.apache.flink.state.changelog.AbstractChangelogStateBackend.createKeyedStateBackend(AbstractChangelogStateBackend.java:136)
Nov 18 06:00:11 at org.apache.flink.streaming.api.operators.StreamTaskStateInitializerImpl.lambda$keyedStatedBackend$1(StreamTaskStateInitializerImpl.java:336)
Nov 18 06:00:11 at org.apache.flink.streaming.api.operators.BackendRestorerProcedure.attemptCreateAndRestore(BackendRestorerProcedure.java:168)
Nov 18 06:00:11 at org.apache.flink.streaming.api.operators.BackendRestorerProcedure.createAndRestore(BackendRestorerProcedure.java:135)
Nov 18 06:00:11 ... 13 more
Nov 18 06:00:11 Caused by: java.io.FileNotFoundException: /tmp/junit7849331111491208454/junit6019736675453245587/8e0bcf531bdfb49f9cc23855d307e0ea/dstl/aee1f583-55a5-4f33-88ba-b50a5bd86386 (No such file or directory)
Nov 18 06:00:11 at java.io.FileInputStream.open0(Native Method)
Nov 18 06:00:11 at java.io.FileInputStream.open(FileInputStream.java:195)
Nov 18 06:00:11 at java.io.FileInputStream.<init>(FileInputStream.java:138)
Nov 18 06:00:11 at org.apache.flink.core.fs.local.LocalDataInputStream.<init>(LocalDataInputStream.java:50)
Nov 18 06:00:11 at org.apache.flink.core.fs.local.LocalFileSystem.open(LocalFileSystem.java:134)
Nov 18 06:00:11 at org.apache.flink.core.fs.SafetyNetWrapperFileSystem.open(SafetyNetWrapperFileSystem.java:87)
Nov 18 06:00:11 at org.apache.flink.runtime.state.filesystem.FileStateHandle.openInputStream(FileStateHandle.java:69)
Nov 18 06:00:11 at org.apache.flink.changelog.fs.ChangelogStreamHandleReaderWithCache.openAndSeek(ChangelogStreamHandleReaderWithCache.java:89)
Nov 18 06:00:11 at org.apache.flink.changelog.fs.StateChangeIteratorImpl.read(StateChangeIteratorImpl.java:42)
Nov 18 06:00:11 at org.apache.flink.runtime.state.changelog.StateChangelogHandleStreamHandleReader$1.advance(StateChangelogHandleStreamHandleReader.java:85)
Nov 18 06:00:11 ... 21 more
> Unstable test ChangelogRecoveryITCase#testMaterialization failed on azure
> -------------------------------------------------------------------------
>
> Key: FLINK-30107
> URL: https://issues.apache.org/jira/browse/FLINK-30107
> Project: Flink
> Issue Type: Bug
> Components: Runtime / Checkpointing
> Affects Versions: 1.16.0
> Reporter: Leonard Xu
> Priority: Major
>
> {noformat}
> Nov 18 06:18:39 [ERROR] Errors:
> Nov 18 06:18:39 [ERROR] ChangelogRecoveryITCase.testMaterialization
> Nov 18 06:18:39 [INFO] Run 1: PASS
> Nov 18 06:18:39 [ERROR] Run 2: org.apache.flink.runtime.JobException: Recovery is suppressed by FixedDelayRestartBackoffTimeStrategy(maxNumberRestartAttempts=2, backoffTimeMS=0)
> Nov 18 06:18:39 [INFO] Run 3: PASS
> Nov 18 06:18:39 [INFO]
> Nov 18 06:18:39 [INFO]
> {noformat}
> https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=43279&view=logs&j=4d4a0d10-fca2-5507-8eed-c07f0bdf4887&t=7b25afdf-cc6c-566f-5459-359dc2585798
--
This message was sent by Atlassian Jira
(v8.20.10#820010)