You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/02/24 11:56:00 UTC
[jira] [Updated] (FLINK-8769) Quickstart job execution in IDE logs
contain several exceptions
[ 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)