flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "ASF GitHub Bot (JIRA)" <j...@apache.org>
Subject [jira] [Commented] (FLINK-8769) Quickstart job execution in IDE logs contain several exceptions
Date Fri, 02 Mar 2018 15:52:00 GMT

    [ 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)

Mime
View raw message