[
https://issues.apache.org/jira/browse/FLINK-30102?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17656670#comment-17656670
]
Matthias Pohl commented on FLINK-30102:
---------------------------------------
I verified that the four previously mentioned builds all have the following
stacktrace as a cause:
{code}
[...]
Caused by: java.lang.Exception: Exception while creating
StreamOperatorStateContext.
at
org.apache.flink.streaming.api.operators.StreamTaskStateInitializerImpl.streamOperatorStateContext(StreamTaskStateInitializerImpl.java:256)
at
org.apache.flink.streaming.api.operators.AbstractStreamOperator.initializeState(AbstractStreamOperator.java:265)
at
org.apache.flink.streaming.runtime.tasks.RegularOperatorChain.initializeStateAndOpenOperators(RegularOperatorChain.java:106)
at
org.apache.flink.streaming.runtime.tasks.StreamTask.restoreGates(StreamTask.java:726)
at
org.apache.flink.streaming.runtime.tasks.StreamTaskActionExecutor$1.call(StreamTaskActionExecutor.java:55)
at
org.apache.flink.streaming.runtime.tasks.StreamTask.restoreInternal(StreamTask.java:702)
at
org.apache.flink.streaming.runtime.tasks.StreamTask.restore(StreamTask.java:669)
at
org.apache.flink.runtime.taskmanager.Task.runWithSystemExitMonitoring(Task.java:935)
at
org.apache.flink.runtime.taskmanager.Task.restoreAndInvoke(Task.java:904)
at org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:728)
at org.apache.flink.runtime.taskmanager.Task.run(Task.java:550)
at java.lang.Thread.run(Thread.java:748)
Caused by: org.apache.flink.util.FlinkException: Could not restore keyed state
backend for WindowOperator_0a448493b4782967b150582570326227_(1/4) from any of
the 1 provided restore options.
at
org.apache.flink.streaming.api.operators.BackendRestorerProcedure.createAndRestore(BackendRestorerProcedure.java:160)
at
org.apache.flink.streaming.api.operators.StreamTaskStateInitializerImpl.keyedStatedBackend(StreamTaskStateInitializerImpl.java:353)
at
org.apache.flink.streaming.api.operators.StreamTaskStateInitializerImpl.streamOperatorStateContext(StreamTaskStateInitializerImpl.java:165)
... 11 more
Caused by: java.lang.RuntimeException: java.io.FileNotFoundException:
/tmp/junit8961509909544404950/junit8348284241715243278/3478dfeb7b5a21f68e56a89681b18358/dstl/cccb396e-3953-4aea-aba2-4e27e4c85a64
(No such file or directory)
at org.apache.flink.util.ExceptionUtils.rethrow(ExceptionUtils.java:321)
at
org.apache.flink.runtime.state.changelog.StateChangelogHandleStreamHandleReader$1.advance(StateChangelogHandleStreamHandleReader.java:87)
at
org.apache.flink.runtime.state.changelog.StateChangelogHandleStreamHandleReader$1.hasNext(StateChangelogHandleStreamHandleReader.java:69)
at
org.apache.flink.state.changelog.restore.ChangelogBackendRestoreOperation.readBackendHandle(ChangelogBackendRestoreOperation.java:107)
at
org.apache.flink.state.changelog.restore.ChangelogBackendRestoreOperation.restore(ChangelogBackendRestoreOperation.java:78)
at
org.apache.flink.state.changelog.ChangelogStateBackend.restore(ChangelogStateBackend.java:94)
at
org.apache.flink.state.changelog.AbstractChangelogStateBackend.createKeyedStateBackend(AbstractChangelogStateBackend.java:136)
at
org.apache.flink.streaming.api.operators.StreamTaskStateInitializerImpl.lambda$keyedStatedBackend$1(StreamTaskStateInitializerImpl.java:336)
at
org.apache.flink.streaming.api.operators.BackendRestorerProcedure.attemptCreateAndRestore(BackendRestorerProcedure.java:168)
at
org.apache.flink.streaming.api.operators.BackendRestorerProcedure.createAndRestore(BackendRestorerProcedure.java:135)
... 13 more
Caused by: java.io.FileNotFoundException:
/tmp/junit8961509909544404950/junit8348284241715243278/3478dfeb7b5a21f68e56a89681b18358/dstl/cccb396e-3953-4aea-aba2-4e27e4c85a64
(No such file or directory)
at java.io.FileInputStream.open0(Native Method)
at java.io.FileInputStream.open(FileInputStream.java:195)
at java.io.FileInputStream.<init>(FileInputStream.java:138)
at
org.apache.flink.core.fs.local.LocalDataInputStream.<init>(LocalDataInputStream.java:50)
at
org.apache.flink.core.fs.local.LocalFileSystem.open(LocalFileSystem.java:134)
at
org.apache.flink.core.fs.SafetyNetWrapperFileSystem.open(SafetyNetWrapperFileSystem.java:87)
at
org.apache.flink.runtime.state.filesystem.FileStateHandle.openInputStream(FileStateHandle.java:69)
at
org.apache.flink.changelog.fs.ChangelogStreamHandleReaderWithCache.openAndSeek(ChangelogStreamHandleReaderWithCache.java:89)
at
org.apache.flink.changelog.fs.StateChangeIteratorImpl.read(StateChangeIteratorImpl.java:42)
at
org.apache.flink.runtime.state.changelog.StateChangelogHandleStreamHandleReader$1.advance(StateChangelogHandleStreamHandleReader.java:85)
... 21 more
{code}
> Unstable test
> EventTimeWindowCheckpointingITCase.testPreAggregatedSlidingTimeWindow failed
> runs on azure
> --------------------------------------------------------------------------------------------------------
>
> Key: FLINK-30102
> URL: https://issues.apache.org/jira/browse/FLINK-30102
> Project: Flink
> Issue Type: Bug
> Components: Runtime / Checkpointing, Runtime / State Backends, Tests
> Affects Versions: 1.16.0
> Reporter: Leonard Xu
> Priority: Major
> Labels: test-stability
>
>
> {noformat}
> Nov 20 06:26:32 [ERROR] Failures:
> Nov 20 06:26:32 [ERROR]
> EventTimeWindowCheckpointingITCase.testPreAggregatedSlidingTimeWindow
> Nov 20 06:26:32 [INFO] Run 1: PASS
> Nov 20 06:26:32 [ERROR] Run 2: Job execution failed.
> Nov 20 06:26:32 [INFO] Run 3: PASS
> Nov 20 06:26:32 [INFO] Run 4: PASS
> Nov 20 06:26:32 [INFO] Run 5: PASS
> Nov 20 06:26:32 [INFO] Run 6: PASS
> Nov 20 06:26:32 [INFO] Run 7: PASS
> Nov 20 06:26:32 [INFO] Run 8: PASS
> Nov 20 06:26:32 [INFO] Run 9: PASS
> Nov 20 06:26:32 [INFO] Run 10: PASS
> {noformat}
> https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=43319&view=logs&j=4d4a0d10-fca2-5507-8eed-c07f0bdf4887&t=7b25afdf-cc6c-566f-5459-359dc2585798&l=10358
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
