[ 
https://issues.apache.org/jira/browse/FLINK-8769?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16383717#comment-16383717
 ] 

ASF GitHub Bot commented on FLINK-8769:
---------------------------------------

Github user GJL commented on a diff in the pull request:

    https://github.com/apache/flink/pull/5611#discussion_r171883413
  
    --- Diff: 
flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/DispatcherRestEndpoint.java
 ---
    @@ -120,7 +120,12 @@ public DispatcherRestEndpoint(
                                // register extension handlers
                                
handlers.addAll(webSubmissionExtension.getHandlers());
                        } catch (FlinkException e) {
    -                           log.info("Failed to load web based job 
submission extension.", e);
    +                           if (log.isDebugEnabled()) {
    +                                   log.debug("Failed to load web based job 
submission extension.", e);
    +                           } else {
    +                                   log.info("Failed to load web based job 
submission extension. " +
    --- End diff --
    
    It still sounds like an error. Maybe `Web based job submission is disabled. 
Probable reason: [...]`


> Quickstart job execution in IDE logs contain several exceptions
> ---------------------------------------------------------------
>
>                 Key: FLINK-8769
>                 URL: https://issues.apache.org/jira/browse/FLINK-8769
>             Project: Flink
>          Issue Type: Bug
>          Components: Local Runtime
>    Affects Versions: 1.5.0
>            Reporter: Chesnay Schepler
>            Assignee: Nico Kruber
>            Priority: Blocker
>             Fix For: 1.5.0
>
>
> While checking out [the PR for 
> FLINK-8761|https://github.com/apache/flink/pull/5569] and running a job in 
> the IDE several exceptions are being logged. The job still runs properly 
> though.
> {code:java}
> ...
> 14:19:52,546 INFO  org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint 
>    - Failed to load web based job submission extension.
> org.apache.flink.util.FlinkException: Could not load web submission extension.
>       at 
> org.apache.flink.runtime.webmonitor.WebMonitorUtils.loadWebSubmissionExtension(WebMonitorUtils.java:252)
>       at 
> org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint.initializeHandlers(DispatcherRestEndpoint.java:111)
>       at 
> org.apache.flink.runtime.rest.RestServerEndpoint.start(RestServerEndpoint.java:124)
>       at 
> org.apache.flink.runtime.minicluster.MiniCluster.start(MiniCluster.java:320)
>       at 
> org.apache.flink.client.LocalExecutor.createJobExecutorService(LocalExecutor.java:144)
>       at org.apache.flink.client.LocalExecutor.start(LocalExecutor.java:118)
>       at 
> org.apache.flink.client.LocalExecutor.executePlan(LocalExecutor.java:212)
>       at 
> org.apache.flink.api.java.LocalEnvironment.execute(LocalEnvironment.java:91)
>       at 
> org.apache.flink.api.java.ExecutionEnvironment.execute(ExecutionEnvironment.java:815)
>       at org.apache.flink.api.java.DataSet.collect(DataSet.java:413)
>       at org.apache.flink.api.java.DataSet.print(DataSet.java:1652)
>       at iqst.BatchJob.main(BatchJob.java:39)
> Caused by: java.lang.reflect.InvocationTargetException
>       at sun.reflect.NativeConstructorAccessorImpl.newInstance0(Native Method)
>       at 
> sun.reflect.NativeConstructorAccessorImpl.newInstance(NativeConstructorAccessorImpl.java:62)
>       at 
> sun.reflect.DelegatingConstructorAccessorImpl.newInstance(DelegatingConstructorAccessorImpl.java:45)
>       at java.lang.reflect.Constructor.newInstance(Constructor.java:423)
>       at 
> org.apache.flink.runtime.webmonitor.WebMonitorUtils.loadWebSubmissionExtension(WebMonitorUtils.java:243)
>       ... 11 more
> Caused by: org.apache.flink.util.ConfigurationException: Config parameter 
> 'Key: 'jobmanager.rpc.address' , default: null (deprecated keys: [])' is 
> missing (hostname/address of JobManager to connect to).
>       at 
> org.apache.flink.runtime.highavailability.HighAvailabilityServicesUtils.getJobManagerAddress(HighAvailabilityServicesUtils.java:137)
>       at 
> org.apache.flink.runtime.highavailability.HighAvailabilityServicesUtils.createHighAvailabilityServices(HighAvailabilityServicesUtils.java:79)
>       at 
> org.apache.flink.client.program.ClusterClient.<init>(ClusterClient.java:148)
>       at 
> org.apache.flink.client.program.rest.RestClusterClient.<init>(RestClusterClient.java:144)
>       at 
> org.apache.flink.client.program.rest.RestClusterClient.<init>(RestClusterClient.java:135)
>       at 
> org.apache.flink.runtime.webmonitor.WebSubmissionExtension.<init>(WebSubmissionExtension.java:61)
>       ... 16 more
> 14:19:53,140 INFO  org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint 
>    - Rest endpoint listening at 127.0.0.1:64908
> ...
> 14:19:56,546 INFO  org.apache.flink.runtime.taskexecutor.TaskExecutor         
>    - Close ResourceManager connection b8a2cff59ba07813067a64ebaf7d7889.
> org.apache.flink.util.FlinkException: New ResourceManager leader found under: 
> null(null)
>       at 
> org.apache.flink.runtime.taskexecutor.TaskExecutor.notifyOfNewResourceManagerLeader(TaskExecutor.java:853)
>       at 
> org.apache.flink.runtime.taskexecutor.TaskExecutor.access$900(TaskExecutor.java:127)
>       at 
> org.apache.flink.runtime.taskexecutor.TaskExecutor$ResourceManagerLeaderListener.lambda$notifyLeaderAddress$0(TaskExecutor.java:1359)
>       at 
> org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRunAsync(AkkaRpcActor.java:292)
>       at 
> org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleMessage(AkkaRpcActor.java:147)
>       at 
> org.apache.flink.runtime.rpc.akka.AkkaRpcActor.lambda$onReceive$0(AkkaRpcActor.java:129)
>       at 
> akka.actor.ActorCell$$anonfun$become$1.applyOrElse(ActorCell.scala:544)
>       at akka.actor.Actor$class.aroundReceive(Actor.scala:502)
>       at akka.actor.UntypedActor.aroundReceive(UntypedActor.scala:95)
>       at akka.actor.ActorCell.receiveMessage(ActorCell.scala:526)
>       at akka.actor.ActorCell.invoke(ActorCell.scala:495)
>       at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:257)
>       at akka.dispatch.Mailbox.run(Mailbox.scala:224)
>       at akka.dispatch.Mailbox.exec(Mailbox.scala:234)
>       at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260)
>       at 
> scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339)
>       at 
> scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979)
>       at 
> scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107)
> ...
> java.lang.Exception: Leader election service is shutting down
>       at 
> org.apache.flink.runtime.highavailability.nonha.embedded.EmbeddedLeaderService.shutdown(EmbeddedLeaderService.java:93)
>       at 
> org.apache.flink.runtime.highavailability.nonha.embedded.EmbeddedHaServices.close(EmbeddedHaServices.java:152)
>       at 
> org.apache.flink.runtime.highavailability.nonha.AbstractNonHaServices.closeAndCleanupAllData(AbstractNonHaServices.java:110)
>       at 
> org.apache.flink.runtime.minicluster.MiniCluster.shutdownInternally(MiniCluster.java:498)
>       at 
> org.apache.flink.runtime.minicluster.MiniCluster.shutdown(MiniCluster.java:380)
>       at 
> org.apache.flink.runtime.minicluster.MiniCluster.closeAsync(MiniCluster.java:790)
>       at 
> org.apache.flink.util.AutoCloseableAsync.close(AutoCloseableAsync.java:40)
>       at org.apache.flink.client.LocalExecutor.stop(LocalExecutor.java:163)
>       at 
> org.apache.flink.client.LocalExecutor.executePlan(LocalExecutor.java:235)
>       at 
> org.apache.flink.api.java.LocalEnvironment.execute(LocalEnvironment.java:91)
>       at 
> org.apache.flink.api.java.ExecutionEnvironment.execute(ExecutionEnvironment.java:815)
>       at org.apache.flink.api.java.DataSet.collect(DataSet.java:413)
>       at org.apache.flink.api.java.DataSet.print(DataSet.java:1652)
>       at iqst.BatchJob.main(BatchJob.java:39)
> 14:19:57,450 ERROR org.apache.flink.runtime.minicluster.MiniCluster           
>    - TaskManager #0 failed.
> java.lang.Exception: Leader election service is shutting down
>       at 
> org.apache.flink.runtime.highavailability.nonha.embedded.EmbeddedLeaderService.shutdown(EmbeddedLeaderService.java:93)
>       at 
> org.apache.flink.runtime.highavailability.nonha.embedded.EmbeddedHaServices.close(EmbeddedHaServices.java:152)
>       at 
> org.apache.flink.runtime.highavailability.nonha.AbstractNonHaServices.closeAndCleanupAllData(AbstractNonHaServices.java:110)
>       at 
> org.apache.flink.runtime.minicluster.MiniCluster.shutdownInternally(MiniCluster.java:498)
>       at 
> org.apache.flink.runtime.minicluster.MiniCluster.shutdown(MiniCluster.java:380)
>       at 
> org.apache.flink.runtime.minicluster.MiniCluster.closeAsync(MiniCluster.java:790)
>       at 
> org.apache.flink.util.AutoCloseableAsync.close(AutoCloseableAsync.java:40)
>       at org.apache.flink.client.LocalExecutor.stop(LocalExecutor.java:163)
>       at 
> org.apache.flink.client.LocalExecutor.executePlan(LocalExecutor.java:235)
>       at 
> org.apache.flink.api.java.LocalEnvironment.execute(LocalEnvironment.java:91)
>       at 
> org.apache.flink.api.java.ExecutionEnvironment.execute(ExecutionEnvironment.java:815)
>       at org.apache.flink.api.java.DataSet.collect(DataSet.java:413)
>       at org.apache.flink.api.java.DataSet.print(DataSet.java:1652)
>       at iqst.BatchJob.main(BatchJob.java:39)
> {code}



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)

Reply via email to