1996fanrui commented on PR #27095: URL: https://github.com/apache/flink/pull/27095#issuecomment-3385826393
> There is a test failure but it's unrelated: > > ``` > Oct 09 11:22:03 11:22:03.127 [ERROR] org.apache.flink.test.checkpointing.UnalignedCheckpointITCase.execute[union with mixed channels, p = 5, timeout = 0] -- Time elapsed: 300.5 s <<< ERROR! > ... > Oct 09 11:22:03 Caused by: org.apache.flink.runtime.jobmanager.scheduler.NoResourceAvailableException: Could not acquire the minimum required resources. > ``` > > @1996fanrui any idea, because we've just touched the unaligned checkpoint part? I analyzed the log from https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=70122&view=results It seems the TM is crashed since NPE, resulting in the resource is not sufficient, so it is not caused by UC. I think it should be a problem with the test itself. ``` 11:16:57,483 [ Sink: sink (5/5)#3] ERROR org.apache.flink.runtime.taskexecutor.TaskExecutor [] - FATAL - exception in exception handler of task Sink: sink (5/5)#3 (ab4ac6968943e64acfb5047f3f2ed3fc_2e588c e1c86a9d46e2e85186773ce4fd_4_3). java.lang.NullPointerException: Cannot read field "numOutput" because "this.state" is null at org.apache.flink.test.checkpointing.UnalignedCheckpointTestBase$VerifyingSinkBase.close(UnalignedCheckpointTestBase.java:1050) ~[test-classes/:?] at org.apache.flink.api.common.functions.util.FunctionUtils.closeFunction(FunctionUtils.java:41) ~[flink-core-2.2-SNAPSHOT.jar:2.2-SNAPSHOT] at org.apache.flink.streaming.api.operators.AbstractUdfStreamOperator.close(AbstractUdfStreamOperator.java:121) ~[flink-runtime-2.2-SNAPSHOT.jar:2.2-SNAPSHOT] at org.apache.flink.streaming.runtime.tasks.StreamOperatorWrapper.close(StreamOperatorWrapper.java:163) ~[flink-runtime-2.2-SNAPSHOT.jar:2.2-SNAPSHOT] at org.apache.flink.streaming.runtime.tasks.RegularOperatorChain.closeAllOperators(RegularOperatorChain.java:125) ~[flink-runtime-2.2-SNAPSHOT.jar:2.2-SNAPSHOT] at org.apache.flink.streaming.runtime.tasks.StreamTask.closeAllOperators(StreamTask.java:1197) ~[flink-runtime-2.2-SNAPSHOT.jar:2.2-SNAPSHOT] at org.apache.flink.util.IOUtils.closeAll(IOUtils.java:257) ~[flink-core-2.2-SNAPSHOT.jar:2.2-SNAPSHOT] at org.apache.flink.core.fs.AutoCloseableRegistry.doClose(AutoCloseableRegistry.java:83) ~[flink-core-2.2-SNAPSHOT.jar:2.2-SNAPSHOT] at org.apache.flink.util.AbstractAutoCloseableRegistry.close(AbstractAutoCloseableRegistry.java:127) ~[flink-core-2.2-SNAPSHOT.jar:2.2-SNAPSHOT] at org.apache.flink.streaming.runtime.tasks.StreamTask.cleanUp(StreamTask.java:1101) ~[flink-runtime-2.2-SNAPSHOT.jar:2.2-SNAPSHOT] at org.apache.flink.runtime.taskmanager.Task.lambda$restoreAndInvoke$2(Task.java:958) ~[flink-runtime-2.2-SNAPSHOT.jar:2.2-SNAPSHOT] at org.apache.flink.runtime.taskmanager.Task.runWithSystemExitMonitoring(Task.java:973) ~[flink-runtime-2.2-SNAPSHOT.jar:2.2-SNAPSHOT] at org.apache.flink.runtime.taskmanager.Task.lambda$restoreAndInvoke$3(Task.java:958) [flink-runtime-2.2-SNAPSHOT.jar:2.2-SNAPSHOT] at org.apache.flink.util.IOUtils.closeAll(IOUtils.java:257) ~[flink-core-2.2-SNAPSHOT.jar:2.2-SNAPSHOT] at org.apache.flink.core.fs.AutoCloseableRegistry.doClose(AutoCloseableRegistry.java:83) ~[flink-core-2.2-SNAPSHOT.jar:2.2-SNAPSHOT] at org.apache.flink.util.AbstractAutoCloseableRegistry.close(AbstractAutoCloseableRegistry.java:127) ~[flink-core-2.2-SNAPSHOT.jar:2.2-SNAPSHOT] at org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:794) [flink-runtime-2.2-SNAPSHOT.jar:2.2-SNAPSHOT] at org.apache.flink.runtime.taskmanager.Task.run(Task.java:569) [flink-runtime-2.2-SNAPSHOT.jar:2.2-SNAPSHOT] at java.base/java.lang.Thread.run(Thread.java:833) [?:?] 11:16:57,483 [ Sink: sink (5/5)#3] ERROR org.apache.flink.runtime.minicluster.MiniCluster [] - TaskManager #2 failed. java.lang.NullPointerException: Cannot read field "numOutput" because "this.state" is null at org.apache.flink.test.checkpointing.UnalignedCheckpointTestBase$VerifyingSinkBase.close(UnalignedCheckpointTestBase.java:1050) ~[test-classes/:?] at org.apache.flink.api.common.functions.util.FunctionUtils.closeFunction(FunctionUtils.java:41) ~[flink-core-2.2-SNAPSHOT.jar:2.2-SNAPSHOT] at org.apache.flink.streaming.api.operators.AbstractUdfStreamOperator.close(AbstractUdfStreamOperator.java:121) ~[flink-runtime-2.2-SNAPSHOT.jar:2.2-SNAPSHOT] at org.apache.flink.streaming.runtime.tasks.StreamOperatorWrapper.close(StreamOperatorWrapper.java:163) ~[flink-runtime-2.2-SNAPSHOT.jar:2.2-SNAPSHOT] at org.apache.flink.streaming.runtime.tasks.RegularOperatorChain.closeAllOperators(RegularOperatorChain.java:125) ~[flink-runtime-2.2-SNAPSHOT.jar:2.2-SNAPSHOT] at org.apache.flink.streaming.runtime.tasks.StreamTask.closeAllOperators(StreamTask.java:1197) ~[flink-runtime-2.2-SNAPSHOT.jar:2.2-SNAPSHOT] at org.apache.flink.util.IOUtils.closeAll(IOUtils.java:257) ~[flink-core-2.2-SNAPSHOT.jar:2.2-SNAPSHOT] at org.apache.flink.core.fs.AutoCloseableRegistry.doClose(AutoCloseableRegistry.java:83) ~[flink-core-2.2-SNAPSHOT.jar:2.2-SNAPSHOT] at org.apache.flink.util.AbstractAutoCloseableRegistry.close(AbstractAutoCloseableRegistry.java:127) ~[flink-core-2.2-SNAPSHOT.jar:2.2-SNAPSHOT] at org.apache.flink.streaming.runtime.tasks.StreamTask.cleanUp(StreamTask.java:1101) ~[flink-runtime-2.2-SNAPSHOT.jar:2.2-SNAPSHOT] at org.apache.flink.runtime.taskmanager.Task.lambda$restoreAndInvoke$2(Task.java:958) ~[flink-runtime-2.2-SNAPSHOT.jar:2.2-SNAPSHOT] at org.apache.flink.runtime.taskmanager.Task.runWithSystemExitMonitoring(Task.java:973) ~[flink-runtime-2.2-SNAPSHOT.jar:2.2-SNAPSHOT] at org.apache.flink.runtime.taskmanager.Task.lambda$restoreAndInvoke$3(Task.java:958) [flink-runtime-2.2-SNAPSHOT.jar:2.2-SNAPSHOT] at org.apache.flink.util.IOUtils.closeAll(IOUtils.java:257) ~[flink-core-2.2-SNAPSHOT.jar:2.2-SNAPSHOT] at org.apache.flink.core.fs.AutoCloseableRegistry.doClose(AutoCloseableRegistry.java:83) ~[flink-core-2.2-SNAPSHOT.jar:2.2-SNAPSHOT] at org.apache.flink.util.AbstractAutoCloseableRegistry.close(AbstractAutoCloseableRegistry.java:127) ~[flink-core-2.2-SNAPSHOT.jar:2.2-SNAPSHOT] at org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:794) [flink-runtime-2.2-SNAPSHOT.jar:2.2-SNAPSHOT] at org.apache.flink.runtime.taskmanager.Task.run(Task.java:569) [flink-runtime-2.2-SNAPSHOT.jar:2.2-SNAPSHOT] at java.base/java.lang.Thread.run(Thread.java:833) [?:?] ``` -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
