You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@flink.apache.org by "Matthias Pohl (Jira)" <ji...@apache.org> on 2022/02/01 08:25:00 UTC
[jira] [Created] (FLINK-25902) NullPointerException in RescalingITCase.testSavepointRescalingOutKeyedState
Matthias Pohl created FLINK-25902:
-------------------------------------
Summary: NullPointerException in RescalingITCase.testSavepointRescalingOutKeyedState
Key: FLINK-25902
URL: https://issues.apache.org/jira/browse/FLINK-25902
Project: Flink
Issue Type: Bug
Components: Runtime / Checkpointing
Affects Versions: 1.15.0
Reporter: Matthias Pohl
I experienced a [build failure|https://dev.azure.com/mapohl/flink/_build/results?buildId=659&view=logs&j=0a15d512-44ac-5ba5-97ab-13a5d066c22c&t=9a028d19-6c4b-5a4e-d378-03fca149d0b1&l=10189] in {{RescalingITCase.testSavepointRescalingOutKeyedState}} with a {{NullPointerException}} appearing:
{code:java}
java.util.concurrent.CancellationException: null
at java.util.concurrent.CompletableFuture.cancel(CompletableFuture.java:2276) ~[?:1.8.0_292]
at org.apache.flink.runtime.state.StateUtil.discardStateFuture(StateUtil.java:78) ~[flink-runtime-1.15-SNAPSHOT.jar:1.15-SNAPSHOT]
at org.apache.flink.streaming.api.operators.OperatorSnapshotFutures.lambda$cancel$0(OperatorSnapshotFutures.java:173) ~[flink-streaming-java-1.15-SNAPSHOT.jar:1.15-SNAPSHOT]
at org.apache.flink.shaded.guava30.com.google.common.io.Closer.close(Closer.java:213) ~[flink-shaded-guava-30.1.1-jre-14.0.jar:30.1.1-jre-14.0]
at org.apache.flink.streaming.api.operators.OperatorSnapshotFutures.cancel(OperatorSnapshotFutures.java:185) ~[flink-streaming-java-1.15-SNAPSHOT.jar:1.15-SNAPSHOT]
at org.apache.flink.streaming.runtime.tasks.AsyncCheckpointRunnable.cleanup(AsyncCheckpointRunnable.java:391) ~[flink-streaming-java-1.15-SNAPSHOT.jar:1.15-SNAPSHOT]
at org.apache.flink.streaming.runtime.tasks.AsyncCheckpointRunnable.close(AsyncCheckpointRunnable.java:356) ~[flink-streaming-java-1.15-SNAPSHOT.jar:1.15-SNAPSHOT]
at org.apache.flink.util.IOUtils.closeQuietly(IOUtils.java:294) ~[flink-core-1.15-SNAPSHOT.jar:1.15-SNAPSHOT]
at org.apache.flink.util.IOUtils.closeAllQuietly(IOUtils.java:281) ~[flink-core-1.15-SNAPSHOT.jar:1.15-SNAPSHOT]
at org.apache.flink.streaming.runtime.tasks.SubtaskCheckpointCoordinatorImpl.close(SubtaskCheckpointCoordinatorImpl.java:480) ~[flink-streaming-java-1.15-SNAPSHOT.jar:1.15-SNAPSHOT]
at org.apache.flink.util.IOUtils.closeQuietly(IOUtils.java:294) ~[flink-core-1.15-SNAPSHOT.jar:1.15-SNAPSHOT]
at org.apache.flink.util.IOUtils.closeAllQuietly(IOUtils.java:281) ~[flink-core-1.15-SNAPSHOT.jar:1.15-SNAPSHOT]
at org.apache.flink.core.fs.CloseableRegistry.doClose(CloseableRegistry.java:74) ~[flink-core-1.15-SNAPSHOT.jar:1.15-SNAPSHOT]
at org.apache.flink.util.AbstractAutoCloseableRegistry.close(AbstractAutoCloseableRegistry.java:127) ~[flink-core-1.15-SNAPSHOT.jar:1.15-SNAPSHOT]
at org.apache.flink.util.IOUtils.closeAll(IOUtils.java:254) ~[flink-core-1.15-SNAPSHOT.jar:1.15-SNAPSHOT]
at org.apache.flink.core.fs.AutoCloseableRegistry.doClose(AutoCloseableRegistry.java:72) ~[flink-core-1.15-SNAPSHOT.jar:1.15-SNAPSHOT]
at org.apache.flink.util.AbstractAutoCloseableRegistry.close(AbstractAutoCloseableRegistry.java:127) ~[flink-core-1.15-SNAPSHOT.jar:1.15-SNAPSHOT]
at org.apache.flink.streaming.runtime.tasks.StreamTask.cleanUp(StreamTask.java:914) ~[flink-streaming-java-1.15-SNAPSHOT.jar:1.15-SNAPSHOT]
at org.apache.flink.runtime.taskmanager.Task.lambda$restoreAndInvoke$0(Task.java:930) ~[flink-runtime-1.15-SNAPSHOT.jar:1.15-SNAPSHOT]
at org.apache.flink.runtime.taskmanager.Task.runWithSystemExitMonitoring(Task.java:948) ~[flink-runtime-1.15-SNAPSHOT.jar:1.15-SNAPSHOT]
at org.apache.flink.runtime.taskmanager.Task.restoreAndInvoke(Task.java:930) ~[flink-runtime-1.15-SNAPSHOT.jar:1.15-SNAPSHOT]
at org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:741) ~[flink-runtime-1.15-SNAPSHOT.jar:1.15-SNAPSHOT]
at org.apache.flink.runtime.taskmanager.Task.run(Task.java:563) ~[flink-runtime-1.15-SNAPSHOT.jar:1.15-SNAPSHOT]
at java.lang.Thread.run(Thread.java:748) [?:1.8.0_292] {code}
--
This message was sent by Atlassian Jira
(v8.20.1#820001)