You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "Yingjie Cao (Jira)" <ji...@apache.org> on 2022/10/20 07:51:00 UTC
[jira] [Closed] (FLINK-29296) OperatorCoordinatorHolder.create throws NPE
[ https://issues.apache.org/jira/browse/FLINK-29296?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Yingjie Cao closed FLINK-29296.
-------------------------------
Resolution: Fixed
> OperatorCoordinatorHolder.create throws NPE
> -------------------------------------------
>
> Key: FLINK-29296
> URL: https://issues.apache.org/jira/browse/FLINK-29296
> Project: Flink
> Issue Type: Bug
> Components: Runtime / Coordination
> Affects Versions: 1.16.0
> Reporter: Xingbo Huang
> Priority: Critical
>
> {code:java}
> 2022-09-13T15:22:42.3864318Z Sep 13 15:22:42 [ERROR] Tests run: 8, Failures: 0, Errors: 1, Skipped: 0, Time elapsed: 5.633 s <<< FAILURE! - in org.apache.flink.test.streaming.runtime.SourceNAryInputChainingITCase
> 2022-09-13T15:22:42.3865377Z Sep 13 15:22:42 [ERROR] org.apache.flink.test.streaming.runtime.SourceNAryInputChainingITCase.testDirectSourcesOnlyExecution Time elapsed: 0.165 s <<< ERROR!
> 2022-09-13T15:22:42.3867571Z Sep 13 15:22:42 java.lang.RuntimeException: Failed to fetch next result
> 2022-09-13T15:22:42.3919112Z Sep 13 15:22:42 at org.apache.flink.streaming.api.operators.collect.CollectResultIterator.nextResultFromFetcher(CollectResultIterator.java:109)
> 2022-09-13T15:22:42.3920935Z Sep 13 15:22:42 at org.apache.flink.streaming.api.operators.collect.CollectResultIterator.hasNext(CollectResultIterator.java:80)
> 2022-09-13T15:22:42.3922442Z Sep 13 15:22:42 at org.apache.flink.streaming.api.datastream.DataStreamUtils.collectBoundedStream(DataStreamUtils.java:106)
> 2022-09-13T15:22:42.3924085Z Sep 13 15:22:42 at org.apache.flink.test.streaming.runtime.SourceNAryInputChainingITCase.testDirectSourcesOnlyExecution(SourceNAryInputChainingITCase.java:89)
> 2022-09-13T15:22:42.3925493Z Sep 13 15:22:42 at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
> 2022-09-13T15:22:42.3926635Z Sep 13 15:22:42 at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
> 2022-09-13T15:22:42.3928378Z Sep 13 15:22:42 at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
> 2022-09-13T15:22:42.3964273Z Sep 13 15:22:42 at java.lang.reflect.Method.invoke(Method.java:498)
> 2022-09-13T15:22:42.3965054Z Sep 13 15:22:42 at org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:59)
> 2022-09-13T15:22:42.3965788Z Sep 13 15:22:42 at org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
> 2022-09-13T15:22:42.3966508Z Sep 13 15:22:42 at org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:56)
> 2022-09-13T15:22:42.3967476Z Sep 13 15:22:42 at org.junit.internal.runners.statements.InvokeMethod.evaluate(InvokeMethod.java:17)
> 2022-09-13T15:22:42.3968432Z Sep 13 15:22:42 at org.apache.flink.util.TestNameProvider$1.evaluate(TestNameProvider.java:45)
> 2022-09-13T15:22:42.3969233Z Sep 13 15:22:42 at org.junit.rules.TestWatcher$1.evaluate(TestWatcher.java:61)
> 2022-09-13T15:22:42.3969871Z Sep 13 15:22:42 at org.junit.runners.ParentRunner$3.evaluate(ParentRunner.java:306)
> 2022-09-13T15:22:42.3970534Z Sep 13 15:22:42 at org.junit.runners.BlockJUnit4ClassRunner$1.evaluate(BlockJUnit4ClassRunner.java:100)
> 2022-09-13T15:22:42.3971453Z Sep 13 15:22:42 at org.junit.runners.ParentRunner.runLeaf(ParentRunner.java:366)
> 2022-09-13T15:22:42.3972453Z Sep 13 15:22:42 at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:103)
> 2022-09-13T15:22:42.3973193Z Sep 13 15:22:42 at org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:63)
> 2022-09-13T15:22:42.3973857Z Sep 13 15:22:42 at org.junit.runners.ParentRunner$4.run(ParentRunner.java:331)
> 2022-09-13T15:22:42.3974634Z Sep 13 15:22:42 at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:79)
> 2022-09-13T15:22:42.3975420Z Sep 13 15:22:42 at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:329)
> 2022-09-13T15:22:42.3976060Z Sep 13 15:22:42 at org.junit.runners.ParentRunner.access$100(ParentRunner.java:66)
> 2022-09-13T15:22:42.3976689Z Sep 13 15:22:42 at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:293)
> 2022-09-13T15:22:42.3977555Z Sep 13 15:22:42 at org.junit.rules.ExternalResource$1.evaluate(ExternalResource.java:54)
> 2022-09-13T15:22:42.3978248Z Sep 13 15:22:42 at org.junit.rules.ExternalResource$1.evaluate(ExternalResource.java:54)
> 2022-09-13T15:22:42.3978856Z Sep 13 15:22:42 at org.junit.rules.RunRules.evaluate(RunRules.java:20)
> 2022-09-13T15:22:42.3979696Z Sep 13 15:22:42 at org.junit.runners.ParentRunner$3.evaluate(ParentRunner.java:306)
> 2022-09-13T15:22:42.3980716Z Sep 13 15:22:42 at org.junit.runners.ParentRunner.run(ParentRunner.java:413)
> 2022-09-13T15:22:42.3981785Z Sep 13 15:22:42 at org.junit.runner.JUnitCore.run(JUnitCore.java:137)
> 2022-09-13T15:22:42.3982352Z Sep 13 15:22:42 at org.junit.runner.JUnitCore.run(JUnitCore.java:115)
> 2022-09-13T15:22:42.3982989Z Sep 13 15:22:42 at org.junit.vintage.engine.execution.RunnerExecutor.execute(RunnerExecutor.java:42)
> 2022-09-13T15:22:42.3983913Z Sep 13 15:22:42 at org.junit.vintage.engine.VintageTestEngine.executeAllChildren(VintageTestEngine.java:80)
> 2022-09-13T15:22:42.3985205Z Sep 13 15:22:42 at org.junit.vintage.engine.VintageTestEngine.execute(VintageTestEngine.java:72)
> 2022-09-13T15:22:42.3986116Z Sep 13 15:22:42 at org.junit.platform.launcher.core.EngineExecutionOrchestrator.execute(EngineExecutionOrchestrator.java:107)
> 2022-09-13T15:22:42.3987027Z Sep 13 15:22:42 at org.junit.platform.launcher.core.EngineExecutionOrchestrator.execute(EngineExecutionOrchestrator.java:88)
> 2022-09-13T15:22:42.3988003Z Sep 13 15:22:42 at org.junit.platform.launcher.core.EngineExecutionOrchestrator.lambda$execute$0(EngineExecutionOrchestrator.java:54)
> 2022-09-13T15:22:42.3988886Z Sep 13 15:22:42 at org.junit.platform.launcher.core.EngineExecutionOrchestrator.withInterceptedStreams(EngineExecutionOrchestrator.java:67)
> 2022-09-13T15:22:42.3989753Z Sep 13 15:22:42 at org.junit.platform.launcher.core.EngineExecutionOrchestrator.execute(EngineExecutionOrchestrator.java:52)
> 2022-09-13T15:22:42.3990534Z Sep 13 15:22:42 at org.junit.platform.launcher.core.DefaultLauncher.execute(DefaultLauncher.java:114)
> 2022-09-13T15:22:42.3991262Z Sep 13 15:22:42 at org.junit.platform.launcher.core.DefaultLauncher.execute(DefaultLauncher.java:86)
> 2022-09-13T15:22:42.3992048Z Sep 13 15:22:42 at org.junit.platform.launcher.core.DefaultLauncherSession$DelegatingLauncher.execute(DefaultLauncherSession.java:86)
> 2022-09-13T15:22:42.3992887Z Sep 13 15:22:42 at org.junit.platform.launcher.core.SessionPerRequestLauncher.execute(SessionPerRequestLauncher.java:53)
> 2022-09-13T15:22:42.3993670Z Sep 13 15:22:42 at org.apache.maven.surefire.junitplatform.JUnitPlatformProvider.execute(JUnitPlatformProvider.java:188)
> 2022-09-13T15:22:42.3994498Z Sep 13 15:22:42 at org.apache.maven.surefire.junitplatform.JUnitPlatformProvider.invokeAllTests(JUnitPlatformProvider.java:154)
> 2022-09-13T15:22:42.3995471Z Sep 13 15:22:42 at org.apache.maven.surefire.junitplatform.JUnitPlatformProvider.invoke(JUnitPlatformProvider.java:124)
> 2022-09-13T15:22:42.3996252Z Sep 13 15:22:42 at org.apache.maven.surefire.booter.ForkedBooter.runSuitesInProcess(ForkedBooter.java:428)
> 2022-09-13T15:22:42.3997203Z Sep 13 15:22:42 at org.apache.maven.surefire.booter.ForkedBooter.execute(ForkedBooter.java:162)
> 2022-09-13T15:22:42.3998042Z Sep 13 15:22:42 at org.apache.maven.surefire.booter.ForkedBooter.run(ForkedBooter.java:562)
> 2022-09-13T15:22:42.3998717Z Sep 13 15:22:42 at org.apache.maven.surefire.booter.ForkedBooter.main(ForkedBooter.java:548)
> 2022-09-13T15:22:42.3999316Z Sep 13 15:22:42 Caused by: java.io.IOException: Failed to fetch job execution result
> 2022-09-13T15:22:42.4000057Z Sep 13 15:22:42 at org.apache.flink.streaming.api.operators.collect.CollectResultFetcher.getAccumulatorResults(CollectResultFetcher.java:184)
> 2022-09-13T15:22:42.4000925Z Sep 13 15:22:42 at org.apache.flink.streaming.api.operators.collect.CollectResultFetcher.next(CollectResultFetcher.java:121)
> 2022-09-13T15:22:42.4001806Z Sep 13 15:22:42 at org.apache.flink.streaming.api.operators.collect.CollectResultIterator.nextResultFromFetcher(CollectResultIterator.java:106)
> 2022-09-13T15:22:42.4002441Z Sep 13 15:22:42 ... 49 more
> 2022-09-13T15:22:42.4003019Z Sep 13 15:22:42 Caused by: java.util.concurrent.ExecutionException: org.apache.flink.runtime.client.JobExecutionException: Job execution failed.
> 2022-09-13T15:22:42.4003764Z Sep 13 15:22:42 at java.util.concurrent.CompletableFuture.reportGet(CompletableFuture.java:357)
> 2022-09-13T15:22:42.4004418Z Sep 13 15:22:42 at java.util.concurrent.CompletableFuture.get(CompletableFuture.java:1928)
> 2022-09-13T15:22:42.4005239Z Sep 13 15:22:42 at org.apache.flink.streaming.api.operators.collect.CollectResultFetcher.getAccumulatorResults(CollectResultFetcher.java:182)
> 2022-09-13T15:22:42.4005865Z Sep 13 15:22:42 ... 51 more
> 2022-09-13T15:22:42.4006359Z Sep 13 15:22:42 Caused by: org.apache.flink.runtime.client.JobExecutionException: Job execution failed.
> 2022-09-13T15:22:42.4007514Z Sep 13 15:22:42 at org.apache.flink.runtime.jobmaster.JobResult.toJobExecutionResult(JobResult.java:144)
> 2022-09-13T15:22:42.4008348Z Sep 13 15:22:42 at org.apache.flink.runtime.minicluster.MiniClusterJobClient.lambda$getJobExecutionResult$3(MiniClusterJobClient.java:141)
> 2022-09-13T15:22:42.4009146Z Sep 13 15:22:42 at java.util.concurrent.CompletableFuture.uniApply(CompletableFuture.java:616)
> 2022-09-13T15:22:42.4009823Z Sep 13 15:22:42 at java.util.concurrent.CompletableFuture.uniApplyStage(CompletableFuture.java:628)
> 2022-09-13T15:22:42.4010525Z Sep 13 15:22:42 at java.util.concurrent.CompletableFuture.thenApply(CompletableFuture.java:1996)
> 2022-09-13T15:22:42.4011295Z Sep 13 15:22:42 at org.apache.flink.runtime.minicluster.MiniClusterJobClient.getJobExecutionResult(MiniClusterJobClient.java:138)
> 2022-09-13T15:22:42.4012173Z Sep 13 15:22:42 at org.apache.flink.streaming.api.operators.collect.CollectResultFetcher.getAccumulatorResults(CollectResultFetcher.java:181)
> 2022-09-13T15:22:42.4012810Z Sep 13 15:22:42 ... 51 more
> 2022-09-13T15:22:42.4013448Z Sep 13 15:22:42 Caused by: org.apache.flink.runtime.client.JobInitializationException: Could not start the JobMaster.
> 2022-09-13T15:22:42.4014278Z Sep 13 15:22:42 at org.apache.flink.runtime.jobmaster.DefaultJobMasterServiceProcess.lambda$new$0(DefaultJobMasterServiceProcess.java:97)
> 2022-09-13T15:22:42.4015229Z Sep 13 15:22:42 at java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:774)
> 2022-09-13T15:22:42.4015959Z Sep 13 15:22:42 at java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:750)
> 2022-09-13T15:22:42.4016686Z Sep 13 15:22:42 at java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:488)
> 2022-09-13T15:22:42.4017624Z Sep 13 15:22:42 at java.util.concurrent.CompletableFuture$AsyncSupply.run(CompletableFuture.java:1609)
> 2022-09-13T15:22:42.4018352Z Sep 13 15:22:42 at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
> 2022-09-13T15:22:42.4019064Z Sep 13 15:22:42 at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
> 2022-09-13T15:22:42.4019644Z Sep 13 15:22:42 at java.lang.Thread.run(Thread.java:748)
> 2022-09-13T15:22:42.4021477Z Sep 13 15:22:42 Caused by: java.util.concurrent.CompletionException: java.lang.RuntimeException: org.apache.flink.runtime.JobException: Cannot instantiate the coordinator for operator MultipleInputOperator [Source: source-1, Source: source-2, Source: source-3]
> 2022-09-13T15:22:42.4022481Z Sep 13 15:22:42 at java.util.concurrent.CompletableFuture.encodeThrowable(CompletableFuture.java:273)
> 2022-09-13T15:22:42.4023211Z Sep 13 15:22:42 at java.util.concurrent.CompletableFuture.completeThrowable(CompletableFuture.java:280)
> 2022-09-13T15:22:42.4023950Z Sep 13 15:22:42 at java.util.concurrent.CompletableFuture$AsyncSupply.run(CompletableFuture.java:1606)
> 2022-09-13T15:22:42.4024490Z Sep 13 15:22:42 ... 3 more
> 2022-09-13T15:22:42.4025502Z Sep 13 15:22:42 Caused by: java.lang.RuntimeException: org.apache.flink.runtime.JobException: Cannot instantiate the coordinator for operator MultipleInputOperator [Source: source-1, Source: source-2, Source: source-3]
> 2022-09-13T15:22:42.4026394Z Sep 13 15:22:42 at org.apache.flink.util.ExceptionUtils.rethrow(ExceptionUtils.java:321)
> 2022-09-13T15:22:42.4027181Z Sep 13 15:22:42 at org.apache.flink.util.function.FunctionUtils.lambda$uncheckedSupplier$4(FunctionUtils.java:114)
> 2022-09-13T15:22:42.4028117Z Sep 13 15:22:42 at java.util.concurrent.CompletableFuture$AsyncSupply.run(CompletableFuture.java:1604)
> 2022-09-13T15:22:42.4028635Z Sep 13 15:22:42 ... 3 more
> 2022-09-13T15:22:42.4029580Z Sep 13 15:22:42 Caused by: org.apache.flink.runtime.JobException: Cannot instantiate the coordinator for operator MultipleInputOperator [Source: source-1, Source: source-2, Source: source-3]
> 2022-09-13T15:22:42.4030458Z Sep 13 15:22:42 at org.apache.flink.runtime.executiongraph.ExecutionJobVertex.initialize(ExecutionJobVertex.java:229)
> 2022-09-13T15:22:42.4031405Z Sep 13 15:22:42 at org.apache.flink.runtime.executiongraph.DefaultExecutionGraph.initializeJobVertex(DefaultExecutionGraph.java:901)
> 2022-09-13T15:22:42.4032277Z Sep 13 15:22:42 at org.apache.flink.runtime.executiongraph.DefaultExecutionGraph.initializeJobVertices(DefaultExecutionGraph.java:891)
> 2022-09-13T15:22:42.4033150Z Sep 13 15:22:42 at org.apache.flink.runtime.executiongraph.DefaultExecutionGraph.attachJobGraph(DefaultExecutionGraph.java:848)
> 2022-09-13T15:22:42.4034250Z Sep 13 15:22:42 at org.apache.flink.runtime.executiongraph.DefaultExecutionGraph.attachJobGraph(DefaultExecutionGraph.java:830)
> 2022-09-13T15:22:42.4035132Z Sep 13 15:22:42 at org.apache.flink.runtime.executiongraph.DefaultExecutionGraphBuilder.buildGraph(DefaultExecutionGraphBuilder.java:198)
> 2022-09-13T15:22:42.4036060Z Sep 13 15:22:42 at org.apache.flink.runtime.scheduler.DefaultExecutionGraphFactory.createAndRestoreExecutionGraph(DefaultExecutionGraphFactory.java:156)
> 2022-09-13T15:22:42.4037173Z Sep 13 15:22:42 at org.apache.flink.runtime.scheduler.SchedulerBase.createAndRestoreExecutionGraph(SchedulerBase.java:361)
> 2022-09-13T15:22:42.4038096Z Sep 13 15:22:42 at org.apache.flink.runtime.scheduler.SchedulerBase.<init>(SchedulerBase.java:206)
> 2022-09-13T15:22:42.4038824Z Sep 13 15:22:42 at org.apache.flink.runtime.scheduler.DefaultScheduler.<init>(DefaultScheduler.java:134)
> 2022-09-13T15:22:42.4039610Z Sep 13 15:22:42 at org.apache.flink.runtime.scheduler.DefaultSchedulerFactory.createInstance(DefaultSchedulerFactory.java:152)
> 2022-09-13T15:22:42.4040587Z Sep 13 15:22:42 at org.apache.flink.runtime.jobmaster.DefaultSlotPoolServiceSchedulerFactory.createScheduler(DefaultSlotPoolServiceSchedulerFactory.java:119)
> 2022-09-13T15:22:42.4041442Z Sep 13 15:22:42 at org.apache.flink.runtime.jobmaster.JobMaster.createScheduler(JobMaster.java:369)
> 2022-09-13T15:22:42.4042111Z Sep 13 15:22:42 at org.apache.flink.runtime.jobmaster.JobMaster.<init>(JobMaster.java:346)
> 2022-09-13T15:22:42.4042959Z Sep 13 15:22:42 at org.apache.flink.runtime.jobmaster.factories.DefaultJobMasterServiceFactory.internalCreateJobMasterService(DefaultJobMasterServiceFactory.java:123)
> 2022-09-13T15:22:42.4043989Z Sep 13 15:22:42 at org.apache.flink.runtime.jobmaster.factories.DefaultJobMasterServiceFactory.lambda$createJobMasterService$0(DefaultJobMasterServiceFactory.java:95)
> 2022-09-13T15:22:42.4045007Z Sep 13 15:22:42 at org.apache.flink.util.function.FunctionUtils.lambda$uncheckedSupplier$4(FunctionUtils.java:112)
> 2022-09-13T15:22:42.4045573Z Sep 13 15:22:42 ... 4 more
> 2022-09-13T15:22:42.4045981Z Sep 13 15:22:42 Caused by: java.lang.NullPointerException
> 2022-09-13T15:22:42.4046657Z Sep 13 15:22:42 at org.apache.flink.runtime.operators.coordination.OperatorCoordinatorHolder.create(OperatorCoordinatorHolder.java:488)
> 2022-09-13T15:22:42.4047747Z Sep 13 15:22:42 at org.apache.flink.runtime.executiongraph.ExecutionJobVertex.createOperatorCoordinatorHolder(ExecutionJobVertex.java:286)
> 2022-09-13T15:22:42.4048604Z Sep 13 15:22:42 at org.apache.f {code}
> https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=40968&view=logs&j=a57e0635-3fad-5b08-57c7-a4142d7d6fa9&t=2ef0effc-1da1-50e5-c2bd-aab434b1c5b7
--
This message was sent by Atlassian Jira
(v8.20.10#820010)