Chesnay Schepler created FLINK-8769:
---------------------------------------
Summary: Quickstart job submission 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
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)
