[ https://issues.apache.org/jira/browse/FLINK-8769?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Chesnay Schepler updated FLINK-8769: ------------------------------------ Summary: Quickstart job execution in IDE logs contain several exceptions (was: Quickstart job submission logs contain several exceptions) > 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 > 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)