Re: Root Exception can not be shown on Web UI in Flink 1.13.0
Hi Gary, Not sure whether you've seen my question in the Jira issue: May you be able to share the overall JobManager/TaskManager logs with us? That would help us understand the context a bit more on why no TaskManagerLocation was set. Let's move any further correspondence into FLINK-22688 [1] Best, Matthias [1] https://issues.apache.org/jira/browse/FLINK-22688 On Wed, May 19, 2021 at 5:45 AM Gary Wu wrote: > Thanks! I have updated the detail and task manager log in > https://issues.apache.org/jira/browse/FLINK-22688. > > Regards, > -Gary > > On Tue, 18 May 2021 at 16:22, Matthias Pohl > wrote: > >> Sorry, for not getting back earlier. I missed that thread. It looks like >> some wrong assumption on our end. Hence, Yangze and Guowei are right. I'm >> gonna look into the issue. >> >> Matthias >> >> On Fri, May 14, 2021 at 4:21 AM Guowei Ma wrote: >> >>> Hi, Gary >>> >>> I think it might be a bug. So would you like to open a jira for this. >>> And could you share the exception ,which the TaskManagerLocation is >>> null? It might be very helpful to verify the cause. >>> >>> Best, >>> Guowei >>> >>> >>> On Thu, May 13, 2021 at 10:36 AM Yangze Guo wrote: >>> Hi, it seems to be related to FLINK-22276. Thus, I'd involve Matthias to take a look. @Matthias My gut feeling is that not all execution who has failureInfo has been deployed? Best, Yangze Guo On Wed, May 12, 2021 at 10:12 PM Gary Wu wrote: > > Hi, > > We have upgraded our Flink applications to 1.13.0 but we found that Root Exception can not be shown on Web UI with an internal server error message. After opening browser development console and trace the message, we found that there is a exception in jobmanager: > > 2021-05-12 13:30:45,589 ERROR org.apache.flink.runtime.rest.handler.job.JobExceptionsHandler [] - Unhandled exception. > java.lang.IllegalArgumentException: The location must not be null for a non-global failure. > at org.apache.flink.util.Preconditions.checkArgument(Preconditions.java:138) ~[flink-dist_2.12-1.13.0.jar:1.13.0] > at org.apache.flink.runtime.rest.handler.job.JobExceptionsHandler.assertLocalExceptionInfo(JobExceptionsHandler.java:218) ~[flink-dist_2.12-1.13.0.jar:1.13.0] > at org.apache.flink.runtime.rest.handler.job.JobExceptionsHandler.createRootExceptionInfo(JobExceptionsHandler.java:191) ~[flink-dist_2.12-1.13.0.jar:1.13.0] > at java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:195) ~[?:?] > at java.util.stream.SliceOps$1$1.accept(SliceOps.java:199) ~[?:?] > at java.util.ArrayList$ArrayListSpliterator.tryAdvance(ArrayList.java:1632) ~[?:?] > at java.util.stream.ReferencePipeline.forEachWithCancel(ReferencePipeline.java:127) ~[?:?] > at java.util.stream.AbstractPipeline.copyIntoWithCancel(AbstractPipeline.java:502) ~[?:?] > at java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:488) ~[?:?] > at java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:474) ~[?:?] > at java.util.stream.ReduceOps$ReduceOp.evaluateSequential(ReduceOps.java:913) ~[?:?] > at java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:234) ~[?:?] > at java.util.stream.ReferencePipeline.collect(ReferencePipeline.java:578) ~[?:?] > at org.apache.flink.runtime.rest.handler.job.JobExceptionsHandler.createJobExceptionHistory(JobExceptionsHandler.java:169) ~[flink-dist_2.12-1.13.0.jar:1.13.0] > at org.apache.flink.runtime.rest.handler.job.JobExceptionsHandler.createJobExceptionsInfo(JobExceptionsHandler.java:154) ~[flink-dist_2.12-1.13.0.jar:1.13.0] > at org.apache.flink.runtime.rest.handler.job.JobExceptionsHandler.handleRequest(JobExceptionsHandler.java:101) ~[flink-dist_2.12-1.13.0.jar:1.13.0] > at org.apache.flink.runtime.rest.handler.job.JobExceptionsHandler.handleRequest(JobExceptionsHandler.java:63) ~[flink-dist_2.12-1.13.0.jar:1.13.0] > at org.apache.flink.runtime.rest.handler.job.AbstractExecutionGraphHandler.lambda$handleRequest$0(AbstractExecutionGraphHandler.java:87) ~[flink-dist_2.12-1.13.0.jar:1.13.0] > at java.util.concurrent.CompletableFuture$UniApply.tryFire(CompletableFuture.java:642) [?:?] > at java.util.concurrent.CompletableFuture$Completion.run(CompletableFuture.java:478) [?:?] > at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515) [?:?] > at java.util.concurrent.FutureTask.run(FutureTask.java:264) [?:?] > at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:304) [?:?] >
Re: Root Exception can not be shown on Web UI in Flink 1.13.0
Thanks! I have updated the detail and task manager log in https://issues.apache.org/jira/browse/FLINK-22688. Regards, -Gary On Tue, 18 May 2021 at 16:22, Matthias Pohl wrote: > Sorry, for not getting back earlier. I missed that thread. It looks like > some wrong assumption on our end. Hence, Yangze and Guowei are right. I'm > gonna look into the issue. > > Matthias > > On Fri, May 14, 2021 at 4:21 AM Guowei Ma wrote: > >> Hi, Gary >> >> I think it might be a bug. So would you like to open a jira for this. >> And could you share the exception ,which the TaskManagerLocation is null? >> It might be very helpful to verify the cause. >> >> Best, >> Guowei >> >> >> On Thu, May 13, 2021 at 10:36 AM Yangze Guo wrote: >> >>> Hi, it seems to be related to FLINK-22276. Thus, I'd involve Matthias >>> to take a look. >>> >>> @Matthias My gut feeling is that not all execution who has failureInfo >>> has been deployed? >>> >>> Best, >>> Yangze Guo >>> >>> On Wed, May 12, 2021 at 10:12 PM Gary Wu wrote: >>> > >>> > Hi, >>> > >>> > We have upgraded our Flink applications to 1.13.0 but we found that >>> Root Exception can not be shown on Web UI with an internal server error >>> message. After opening browser development console and trace the message, >>> we found that there is a exception in jobmanager: >>> > >>> > 2021-05-12 13:30:45,589 ERROR >>> org.apache.flink.runtime.rest.handler.job.JobExceptionsHandler [] - >>> Unhandled exception. >>> > java.lang.IllegalArgumentException: The location must not be null for >>> a non-global failure. >>> > at >>> org.apache.flink.util.Preconditions.checkArgument(Preconditions.java:138) >>> ~[flink-dist_2.12-1.13.0.jar:1.13.0] >>> > at >>> org.apache.flink.runtime.rest.handler.job.JobExceptionsHandler.assertLocalExceptionInfo(JobExceptionsHandler.java:218) >>> ~[flink-dist_2.12-1.13.0.jar:1.13.0] >>> > at >>> org.apache.flink.runtime.rest.handler.job.JobExceptionsHandler.createRootExceptionInfo(JobExceptionsHandler.java:191) >>> ~[flink-dist_2.12-1.13.0.jar:1.13.0] >>> > at >>> java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:195) >>> ~[?:?] >>> > at java.util.stream.SliceOps$1$1.accept(SliceOps.java:199) ~[?:?] >>> > at >>> java.util.ArrayList$ArrayListSpliterator.tryAdvance(ArrayList.java:1632) >>> ~[?:?] >>> > at >>> java.util.stream.ReferencePipeline.forEachWithCancel(ReferencePipeline.java:127) >>> ~[?:?] >>> > at >>> java.util.stream.AbstractPipeline.copyIntoWithCancel(AbstractPipeline.java:502) >>> ~[?:?] >>> > at >>> java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:488) ~[?:?] >>> > at >>> java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:474) >>> ~[?:?] >>> > at >>> java.util.stream.ReduceOps$ReduceOp.evaluateSequential(ReduceOps.java:913) >>> ~[?:?] >>> > at >>> java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:234) ~[?:?] >>> > at >>> java.util.stream.ReferencePipeline.collect(ReferencePipeline.java:578) >>> ~[?:?] >>> > at >>> org.apache.flink.runtime.rest.handler.job.JobExceptionsHandler.createJobExceptionHistory(JobExceptionsHandler.java:169) >>> ~[flink-dist_2.12-1.13.0.jar:1.13.0] >>> > at >>> org.apache.flink.runtime.rest.handler.job.JobExceptionsHandler.createJobExceptionsInfo(JobExceptionsHandler.java:154) >>> ~[flink-dist_2.12-1.13.0.jar:1.13.0] >>> > at >>> org.apache.flink.runtime.rest.handler.job.JobExceptionsHandler.handleRequest(JobExceptionsHandler.java:101) >>> ~[flink-dist_2.12-1.13.0.jar:1.13.0] >>> > at >>> org.apache.flink.runtime.rest.handler.job.JobExceptionsHandler.handleRequest(JobExceptionsHandler.java:63) >>> ~[flink-dist_2.12-1.13.0.jar:1.13.0] >>> > at >>> org.apache.flink.runtime.rest.handler.job.AbstractExecutionGraphHandler.lambda$handleRequest$0(AbstractExecutionGraphHandler.java:87) >>> ~[flink-dist_2.12-1.13.0.jar:1.13.0] >>> > at >>> java.util.concurrent.CompletableFuture$UniApply.tryFire(CompletableFuture.java:642) >>> [?:?] >>> > at >>> java.util.concurrent.CompletableFuture$Completion.run(CompletableFuture.java:478) >>> [?:?] >>> > at >>> java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515) >>> [?:?] >>> > at java.util.concurrent.FutureTask.run(FutureTask.java:264) [?:?] >>> > at >>> java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:304) >>> [?:?] >>> > at >>> java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128) >>> [?:?] >>> > at >>> java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628) >>> [?:?] >>> > at java.lang.Thread.run(Thread.java:834) [?:?] >>> > >>> > We would like to check Is there any configuration change should be >>> done for the application? Thanks! >>> > >>> > Regards, >>> > -Gary >>> > >>> > >>> > >>> > APPIER EMAIL NOTICE >>> > >>> > The contents of this email message and any attachments from Appier >>> Group
Re: Root Exception can not be shown on Web UI in Flink 1.13.0
Sorry, for not getting back earlier. I missed that thread. It looks like some wrong assumption on our end. Hence, Yangze and Guowei are right. I'm gonna look into the issue. Matthias On Fri, May 14, 2021 at 4:21 AM Guowei Ma wrote: > Hi, Gary > > I think it might be a bug. So would you like to open a jira for this. > And could you share the exception ,which the TaskManagerLocation is null? > It might be very helpful to verify the cause. > > Best, > Guowei > > > On Thu, May 13, 2021 at 10:36 AM Yangze Guo wrote: > >> Hi, it seems to be related to FLINK-22276. Thus, I'd involve Matthias >> to take a look. >> >> @Matthias My gut feeling is that not all execution who has failureInfo >> has been deployed? >> >> Best, >> Yangze Guo >> >> On Wed, May 12, 2021 at 10:12 PM Gary Wu wrote: >> > >> > Hi, >> > >> > We have upgraded our Flink applications to 1.13.0 but we found that >> Root Exception can not be shown on Web UI with an internal server error >> message. After opening browser development console and trace the message, >> we found that there is a exception in jobmanager: >> > >> > 2021-05-12 13:30:45,589 ERROR >> org.apache.flink.runtime.rest.handler.job.JobExceptionsHandler [] - >> Unhandled exception. >> > java.lang.IllegalArgumentException: The location must not be null for a >> non-global failure. >> > at >> org.apache.flink.util.Preconditions.checkArgument(Preconditions.java:138) >> ~[flink-dist_2.12-1.13.0.jar:1.13.0] >> > at >> org.apache.flink.runtime.rest.handler.job.JobExceptionsHandler.assertLocalExceptionInfo(JobExceptionsHandler.java:218) >> ~[flink-dist_2.12-1.13.0.jar:1.13.0] >> > at >> org.apache.flink.runtime.rest.handler.job.JobExceptionsHandler.createRootExceptionInfo(JobExceptionsHandler.java:191) >> ~[flink-dist_2.12-1.13.0.jar:1.13.0] >> > at >> java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:195) >> ~[?:?] >> > at java.util.stream.SliceOps$1$1.accept(SliceOps.java:199) ~[?:?] >> > at >> java.util.ArrayList$ArrayListSpliterator.tryAdvance(ArrayList.java:1632) >> ~[?:?] >> > at >> java.util.stream.ReferencePipeline.forEachWithCancel(ReferencePipeline.java:127) >> ~[?:?] >> > at >> java.util.stream.AbstractPipeline.copyIntoWithCancel(AbstractPipeline.java:502) >> ~[?:?] >> > at >> java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:488) ~[?:?] >> > at >> java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:474) >> ~[?:?] >> > at >> java.util.stream.ReduceOps$ReduceOp.evaluateSequential(ReduceOps.java:913) >> ~[?:?] >> > at >> java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:234) ~[?:?] >> > at >> java.util.stream.ReferencePipeline.collect(ReferencePipeline.java:578) >> ~[?:?] >> > at >> org.apache.flink.runtime.rest.handler.job.JobExceptionsHandler.createJobExceptionHistory(JobExceptionsHandler.java:169) >> ~[flink-dist_2.12-1.13.0.jar:1.13.0] >> > at >> org.apache.flink.runtime.rest.handler.job.JobExceptionsHandler.createJobExceptionsInfo(JobExceptionsHandler.java:154) >> ~[flink-dist_2.12-1.13.0.jar:1.13.0] >> > at >> org.apache.flink.runtime.rest.handler.job.JobExceptionsHandler.handleRequest(JobExceptionsHandler.java:101) >> ~[flink-dist_2.12-1.13.0.jar:1.13.0] >> > at >> org.apache.flink.runtime.rest.handler.job.JobExceptionsHandler.handleRequest(JobExceptionsHandler.java:63) >> ~[flink-dist_2.12-1.13.0.jar:1.13.0] >> > at >> org.apache.flink.runtime.rest.handler.job.AbstractExecutionGraphHandler.lambda$handleRequest$0(AbstractExecutionGraphHandler.java:87) >> ~[flink-dist_2.12-1.13.0.jar:1.13.0] >> > at >> java.util.concurrent.CompletableFuture$UniApply.tryFire(CompletableFuture.java:642) >> [?:?] >> > at >> java.util.concurrent.CompletableFuture$Completion.run(CompletableFuture.java:478) >> [?:?] >> > at >> java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515) >> [?:?] >> > at java.util.concurrent.FutureTask.run(FutureTask.java:264) [?:?] >> > at >> java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:304) >> [?:?] >> > at >> java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128) >> [?:?] >> > at >> java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628) >> [?:?] >> > at java.lang.Thread.run(Thread.java:834) [?:?] >> > >> > We would like to check Is there any configuration change should be done >> for the application? Thanks! >> > >> > Regards, >> > -Gary >> > >> > >> > >> > APPIER EMAIL NOTICE >> > >> > The contents of this email message and any attachments from Appier >> Group Inc. and/or its affiliates may be privileged and confidential. If you >> are not the intended recipient of this email, please note that any >> disclosure, copying, distribution, or use of this message or its >> attachments is prohibited. If you have received this email in error, please >> contact us immediately
Re: Root Exception can not be shown on Web UI in Flink 1.13.0
Hi, Gary I think it might be a bug. So would you like to open a jira for this. And could you share the exception ,which the TaskManagerLocation is null? It might be very helpful to verify the cause. Best, Guowei On Thu, May 13, 2021 at 10:36 AM Yangze Guo wrote: > Hi, it seems to be related to FLINK-22276. Thus, I'd involve Matthias > to take a look. > > @Matthias My gut feeling is that not all execution who has failureInfo > has been deployed? > > Best, > Yangze Guo > > On Wed, May 12, 2021 at 10:12 PM Gary Wu wrote: > > > > Hi, > > > > We have upgraded our Flink applications to 1.13.0 but we found that Root > Exception can not be shown on Web UI with an internal server error message. > After opening browser development console and trace the message, we found > that there is a exception in jobmanager: > > > > 2021-05-12 13:30:45,589 ERROR > org.apache.flink.runtime.rest.handler.job.JobExceptionsHandler [] - > Unhandled exception. > > java.lang.IllegalArgumentException: The location must not be null for a > non-global failure. > > at > org.apache.flink.util.Preconditions.checkArgument(Preconditions.java:138) > ~[flink-dist_2.12-1.13.0.jar:1.13.0] > > at > org.apache.flink.runtime.rest.handler.job.JobExceptionsHandler.assertLocalExceptionInfo(JobExceptionsHandler.java:218) > ~[flink-dist_2.12-1.13.0.jar:1.13.0] > > at > org.apache.flink.runtime.rest.handler.job.JobExceptionsHandler.createRootExceptionInfo(JobExceptionsHandler.java:191) > ~[flink-dist_2.12-1.13.0.jar:1.13.0] > > at > java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:195) > ~[?:?] > > at java.util.stream.SliceOps$1$1.accept(SliceOps.java:199) ~[?:?] > > at > java.util.ArrayList$ArrayListSpliterator.tryAdvance(ArrayList.java:1632) > ~[?:?] > > at > java.util.stream.ReferencePipeline.forEachWithCancel(ReferencePipeline.java:127) > ~[?:?] > > at > java.util.stream.AbstractPipeline.copyIntoWithCancel(AbstractPipeline.java:502) > ~[?:?] > > at > java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:488) ~[?:?] > > at > java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:474) > ~[?:?] > > at > java.util.stream.ReduceOps$ReduceOp.evaluateSequential(ReduceOps.java:913) > ~[?:?] > > at > java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:234) ~[?:?] > > at > java.util.stream.ReferencePipeline.collect(ReferencePipeline.java:578) > ~[?:?] > > at > org.apache.flink.runtime.rest.handler.job.JobExceptionsHandler.createJobExceptionHistory(JobExceptionsHandler.java:169) > ~[flink-dist_2.12-1.13.0.jar:1.13.0] > > at > org.apache.flink.runtime.rest.handler.job.JobExceptionsHandler.createJobExceptionsInfo(JobExceptionsHandler.java:154) > ~[flink-dist_2.12-1.13.0.jar:1.13.0] > > at > org.apache.flink.runtime.rest.handler.job.JobExceptionsHandler.handleRequest(JobExceptionsHandler.java:101) > ~[flink-dist_2.12-1.13.0.jar:1.13.0] > > at > org.apache.flink.runtime.rest.handler.job.JobExceptionsHandler.handleRequest(JobExceptionsHandler.java:63) > ~[flink-dist_2.12-1.13.0.jar:1.13.0] > > at > org.apache.flink.runtime.rest.handler.job.AbstractExecutionGraphHandler.lambda$handleRequest$0(AbstractExecutionGraphHandler.java:87) > ~[flink-dist_2.12-1.13.0.jar:1.13.0] > > at > java.util.concurrent.CompletableFuture$UniApply.tryFire(CompletableFuture.java:642) > [?:?] > > at > java.util.concurrent.CompletableFuture$Completion.run(CompletableFuture.java:478) > [?:?] > > at > java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515) > [?:?] > > at java.util.concurrent.FutureTask.run(FutureTask.java:264) [?:?] > > at > java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:304) > [?:?] > > at > java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128) > [?:?] > > at > java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628) > [?:?] > > at java.lang.Thread.run(Thread.java:834) [?:?] > > > > We would like to check Is there any configuration change should be done > for the application? Thanks! > > > > Regards, > > -Gary > > > > > > > > APPIER EMAIL NOTICE > > > > The contents of this email message and any attachments from Appier Group > Inc. and/or its affiliates may be privileged and confidential. If you are > not the intended recipient of this email, please note that any disclosure, > copying, distribution, or use of this message or its attachments is > prohibited. If you have received this email in error, please contact us > immediately and delete this message and any attachments. >
Re: Root Exception can not be shown on Web UI in Flink 1.13.0
Hi, it seems to be related to FLINK-22276. Thus, I'd involve Matthias to take a look. @Matthias My gut feeling is that not all execution who has failureInfo has been deployed? Best, Yangze Guo On Wed, May 12, 2021 at 10:12 PM Gary Wu wrote: > > Hi, > > We have upgraded our Flink applications to 1.13.0 but we found that Root > Exception can not be shown on Web UI with an internal server error message. > After opening browser development console and trace the message, we found > that there is a exception in jobmanager: > > 2021-05-12 13:30:45,589 ERROR > org.apache.flink.runtime.rest.handler.job.JobExceptionsHandler [] - Unhandled > exception. > java.lang.IllegalArgumentException: The location must not be null for a > non-global failure. > at > org.apache.flink.util.Preconditions.checkArgument(Preconditions.java:138) > ~[flink-dist_2.12-1.13.0.jar:1.13.0] > at > org.apache.flink.runtime.rest.handler.job.JobExceptionsHandler.assertLocalExceptionInfo(JobExceptionsHandler.java:218) > ~[flink-dist_2.12-1.13.0.jar:1.13.0] > at > org.apache.flink.runtime.rest.handler.job.JobExceptionsHandler.createRootExceptionInfo(JobExceptionsHandler.java:191) > ~[flink-dist_2.12-1.13.0.jar:1.13.0] > at > java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:195) > ~[?:?] > at java.util.stream.SliceOps$1$1.accept(SliceOps.java:199) ~[?:?] > at > java.util.ArrayList$ArrayListSpliterator.tryAdvance(ArrayList.java:1632) > ~[?:?] > at > java.util.stream.ReferencePipeline.forEachWithCancel(ReferencePipeline.java:127) > ~[?:?] > at > java.util.stream.AbstractPipeline.copyIntoWithCancel(AbstractPipeline.java:502) > ~[?:?] > at java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:488) > ~[?:?] > at > java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:474) > ~[?:?] > at > java.util.stream.ReduceOps$ReduceOp.evaluateSequential(ReduceOps.java:913) > ~[?:?] > at java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:234) > ~[?:?] > at java.util.stream.ReferencePipeline.collect(ReferencePipeline.java:578) > ~[?:?] > at > org.apache.flink.runtime.rest.handler.job.JobExceptionsHandler.createJobExceptionHistory(JobExceptionsHandler.java:169) > ~[flink-dist_2.12-1.13.0.jar:1.13.0] > at > org.apache.flink.runtime.rest.handler.job.JobExceptionsHandler.createJobExceptionsInfo(JobExceptionsHandler.java:154) > ~[flink-dist_2.12-1.13.0.jar:1.13.0] > at > org.apache.flink.runtime.rest.handler.job.JobExceptionsHandler.handleRequest(JobExceptionsHandler.java:101) > ~[flink-dist_2.12-1.13.0.jar:1.13.0] > at > org.apache.flink.runtime.rest.handler.job.JobExceptionsHandler.handleRequest(JobExceptionsHandler.java:63) > ~[flink-dist_2.12-1.13.0.jar:1.13.0] > at > org.apache.flink.runtime.rest.handler.job.AbstractExecutionGraphHandler.lambda$handleRequest$0(AbstractExecutionGraphHandler.java:87) > ~[flink-dist_2.12-1.13.0.jar:1.13.0] > at > java.util.concurrent.CompletableFuture$UniApply.tryFire(CompletableFuture.java:642) > [?:?] > at > java.util.concurrent.CompletableFuture$Completion.run(CompletableFuture.java:478) > [?:?] > at > java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515) [?:?] > at java.util.concurrent.FutureTask.run(FutureTask.java:264) [?:?] > at > java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:304) > [?:?] > at > java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128) > [?:?] > at > java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628) > [?:?] > at java.lang.Thread.run(Thread.java:834) [?:?] > > We would like to check Is there any configuration change should be done for > the application? Thanks! > > Regards, > -Gary > > > > APPIER EMAIL NOTICE > > The contents of this email message and any attachments from Appier Group Inc. > and/or its affiliates may be privileged and confidential. If you are not the > intended recipient of this email, please note that any disclosure, copying, > distribution, or use of this message or its attachments is prohibited. If you > have received this email in error, please contact us immediately and delete > this message and any attachments.
Root Exception can not be shown on Web UI in Flink 1.13.0
Hi, We have upgraded our Flink applications to 1.13.0 but we found that Root Exception can not be shown on Web UI with an internal server error message. After opening browser development console and trace the message, we found that there is a exception in jobmanager: *2021-05-12 13:30:45,589 ERROR org.apache.flink.runtime.rest.handler.job.JobExceptionsHandler [] - Unhandled exception.* *java.lang.IllegalArgumentException: The location must not be null for a non-global failure.* *at org.apache.flink.util.Preconditions.checkArgument(Preconditions.java:138) ~[flink-dist_2.12-1.13.0.jar:1.13.0]* *at org.apache.flink.runtime.rest.handler.job.JobExceptionsHandler.assertLocalExceptionInfo(JobExceptionsHandler.java:218) ~[flink-dist_2.12-1.13.0.jar:1.13.0]* *at org.apache.flink.runtime.rest.handler.job.JobExceptionsHandler.createRootExceptionInfo(JobExceptionsHandler.java:191) ~[flink-dist_2.12-1.13.0.jar:1.13.0]* *at java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:195) ~[?:?]* *at java.util.stream.SliceOps$1$1.accept(SliceOps.java:199) ~[?:?]* *at java.util.ArrayList$ArrayListSpliterator.tryAdvance(ArrayList.java:1632) ~[?:?]* *at java.util.stream.ReferencePipeline.forEachWithCancel(ReferencePipeline.java:127) ~[?:?]* *at java.util.stream.AbstractPipeline.copyIntoWithCancel(AbstractPipeline.java:502) ~[?:?]* *at java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:488) ~[?:?]* *at java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:474) ~[?:?]* *at java.util.stream.ReduceOps$ReduceOp.evaluateSequential(ReduceOps.java:913) ~[?:?]* *at java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:234) ~[?:?]* *at java.util.stream.ReferencePipeline.collect(ReferencePipeline.java:578) ~[?:?]* *at org.apache.flink.runtime.rest.handler.job.JobExceptionsHandler.createJobExceptionHistory(JobExceptionsHandler.java:169) ~[flink-dist_2.12-1.13.0.jar:1.13.0]* *at org.apache.flink.runtime.rest.handler.job.JobExceptionsHandler.createJobExceptionsInfo(JobExceptionsHandler.java:154) ~[flink-dist_2.12-1.13.0.jar:1.13.0]* *at org.apache.flink.runtime.rest.handler.job.JobExceptionsHandler.handleRequest(JobExceptionsHandler.java:101) ~[flink-dist_2.12-1.13.0.jar:1.13.0]* *at org.apache.flink.runtime.rest.handler.job.JobExceptionsHandler.handleRequest(JobExceptionsHandler.java:63) ~[flink-dist_2.12-1.13.0.jar:1.13.0]* *at org.apache.flink.runtime.rest.handler.job.AbstractExecutionGraphHandler.lambda$handleRequest$0(AbstractExecutionGraphHandler.java:87) ~[flink-dist_2.12-1.13.0.jar:1.13.0]* *at java.util.concurrent.CompletableFuture$UniApply.tryFire(CompletableFuture.java:642) [?:?]* *at java.util.concurrent.CompletableFuture$Completion.run(CompletableFuture.java:478) [?:?]* *at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515) [?:?]* *at java.util.concurrent.FutureTask.run(FutureTask.java:264) [?:?]* *at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:304) [?:?]* *at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128) [?:?]* *at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628) [?:?]* *at java.lang.Thread.run(Thread.java:834) [?:?]* We would like to check Is there any configuration change should be done for the application? Thanks! Regards, -Gary -- *APPIER EMAIL NOTICE* * * The contents of this email message and any attachments from Appier Group Inc. and/or its affiliates may be privileged and confidential. If you are not the intended recipient of this email, please note that any disclosure, copying, distribution, or use of this message or its attachments is prohibited. If you have received this email in error, please contact us immediately and delete this message and any attachments.
