[jira] [Created] (FLINK-15225) LeaderChangeClusterComponentsT
Locked
[jira] [Created] (FLINK-15225) LeaderChangeClusterComponentsT
 
|
Chesnay Schepler created FLINK-15225:
---------------------------------------- Summary: LeaderChangeClusterComponentsTest#testReelectionOfDispatcher occasionally requires 30 seconds Key: FLINK-15225 URL: https://issues.apache.org/jira/browse/FLINK-15225 Project: Flink Issue Type: Improvement Components: Runtime / Coordination, Tests Affects Versions: 1.10.0 Reporter: Chesnay Schepler {code:java} 20845 [flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.resourcemanager.slotmanager.SlotManagerImpl - Starting the SlotManager. 20845 [mini-cluster-io-thread-1] INFO org.apache.flink.runtime.dispatcher.runner.SessionDispatcherLeaderProcess - Recover all persisted job graphs. 20845 [mini-cluster-io-thread-1] INFO org.apache.flink.runtime.dispatcher.runner.SessionDispatcherLeaderProcess - Successfully recovered 0 persisted job graphs. 20845 [flink-akka.actor.default-dispatcher-5] DEBUG org.apache.flink.runtime.resourcemanager.StandaloneResourceManager - Trigger heartbeat request. 20845 [flink-akka.actor.default-dispatcher-5] DEBUG org.apache.flink.runtime.resourcemanager.StandaloneResourceManager - Trigger heartbeat request. 20845 [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.highavailability.nonha.embedded.EmbeddedLeaderService - Received confirmation of leadership for leader akka://flink/user/resourcemanager9fa41f3a-7bd4-4f72-ae07-76b75499c88d , session=e73f31a7-c45f-4328-addd-3d7aa17fd083 20845 [mini-cluster-io-thread-1] INFO org.apache.flink.runtime.rpc.akka.AkkaRpcService - Starting RPC endpoint for org.apache.flink.runtime.dispatcher.StandaloneDispatcher at akka://flink/user/dispatcherd5f8446f-b44d-4bcd-88b3-65105c1c6ca0 . 20845 [pool-1-thread-1] DEBUG org.apache.flink.runtime.rpc.akka.AkkaRpcService - Try to connect to remote RPC endpoint with address akka://flink/user/resourcemanager9fa41f3a-7bd4-4f72-ae07-76b75499c88d. Returning a org.apache.flink.runtime.resourcemanager.ResourceManagerGateway gateway. 20845 [flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Connecting to ResourceManager akka://flink/user/resourcemanager9fa41f3a-7bd4-4f72-ae07-76b75499c88d(addd3d7aa17fd083e73f31a7c45f4328). 20845 [flink-akka.actor.default-dispatcher-5] DEBUG org.apache.flink.runtime.rpc.akka.AkkaRpcService - Try to connect to remote RPC endpoint with address akka://flink/user/resourcemanager9fa41f3a-7bd4-4f72-ae07-76b75499c88d. Returning a org.apache.flink.runtime.resourcemanager.ResourceManagerGateway gateway. 20845 [pool-1-thread-1] DEBUG org.apache.flink.runtime.rpc.akka.AkkaRpcService - Try to connect to remote RPC endpoint with address akka://flink/user/resourcemanager9fa41f3a-7bd4-4f72-ae07-76b75499c88d. Returning a org.apache.flink.runtime.resourcemanager.ResourceManagerGateway gateway. 20846 [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Resolved ResourceManager address, beginning registration 20846 [flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Connecting to ResourceManager akka://flink/user/resourcemanager9fa41f3a-7bd4-4f72-ae07-76b75499c88d(addd3d7aa17fd083e73f31a7c45f4328). 20846 [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Registration at ResourceManager attempt 1 (timeout=100ms) 20846 [flink-akka.actor.default-dispatcher-5] DEBUG org.apache.flink.runtime.rpc.akka.AkkaRpcService - Try to connect to remote RPC endpoint with address akka://flink/user/resourcemanager9fa41f3a-7bd4-4f72-ae07-76b75499c88d. Returning a org.apache.flink.runtime.resourcemanager.ResourceManagerGateway gateway. 20846 [flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Resolved ResourceManager address, beginning registration 20846 [flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Registration at ResourceManager attempt 1 (timeout=100ms) 20846 [flink-akka.actor.default-dispatcher-3] DEBUG org.apache.flink.runtime.rpc.akka.AkkaRpcService - Try to connect to remote RPC endpoint with address akka://flink/user/taskmanager_285. Returning a org.apache.flink.runtime.taskexecutor.TaskExecutorGateway gateway. 20846 [mini-cluster-io-thread-1] INFO org.apache.flink.runtime.highavailability.nonha.embedded.EmbeddedLeaderService - Received confirmation of leadership for leader akka://flink/user/dispatcherd5f8446f-b44d-4bcd-88b3-65105c1c6ca0 , session=d20872e6-0b96-43ea-9da2-7590a255e906 20846 [pool-1-thread-1] DEBUG org.apache.flink.runtime.rpc.akka.AkkaRpcService - Try to connect to remote RPC endpoint with address akka://flink/user/dispatcherd5f8446f-b44d-4bcd-88b3-65105c1c6ca0. Returning a org.apache.flink.runtime.dispatcher.DispatcherGateway gateway. 20846 [flink-akka.actor.default-dispatcher-3] DEBUG org.apache.flink.runtime.rpc.akka.AkkaRpcService - Try to connect to remote RPC endpoint with address akka://flink/user/taskmanager_286. Returning a org.apache.flink.runtime.taskexecutor.TaskExecutorGateway gateway. 20846 [pool-1-thread-1] DEBUG org.apache.flink.runtime.rpc.akka.AkkaRpcService - Try to connect to remote RPC endpoint with address akka://flink/user/dispatcherd5f8446f-b44d-4bcd-88b3-65105c1c6ca0. Returning a org.apache.flink.runtime.dispatcher.DispatcherGateway gateway. 20846 [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.resourcemanager.StandaloneResourceManager - Registering TaskManager with ResourceID 0f553ce4-9ee6-4861-9961-de414cf8d08b (akka://flink/user/taskmanager_285) at ResourceManager 20846 [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.resourcemanager.StandaloneResourceManager - Registering TaskManager with ResourceID 30248eb7-9288-488b-874a-204845181b60 (akka://flink/user/taskmanager_286) at ResourceManager 20846 [flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Successful registration at resource manager akka://flink/user/resourcemanager9fa41f3a-7bd4-4f72-ae07-76b75499c88d under registration id 3075b1693bff8da60555d090ff5123dc. 20846 [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Successful registration at resource manager akka://flink/user/resourcemanager9fa41f3a-7bd4-4f72-ae07-76b75499c88d under registration id 2407f57c0c14584af2107ae72ea04867. 20846 [flink-akka.actor.default-dispatcher-3] DEBUG org.apache.flink.runtime.resourcemanager.slotmanager.SlotManagerImpl - Registering TaskManager 0f553ce4-9ee6-4861-9961-de414cf8d08b under 3075b1693bff8da60555d090ff5123dc at the SlotManager. 20846 [flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Received JobGraph submission 10916cea5ecc0ea53989d755e8699478 (Blocking test job). 20846 [flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Submitting job 10916cea5ecc0ea53989d755e8699478 (Blocking test job). 20846 [flink-akka.actor.default-dispatcher-3] DEBUG org.apache.flink.runtime.resourcemanager.slotmanager.SlotManagerImpl - Registering TaskManager 30248eb7-9288-488b-874a-204845181b60 under 2407f57c0c14584af2107ae72ea04867 at the SlotManager. 20846 [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.rpc.akka.AkkaRpcService - Starting RPC endpoint for org.apache.flink.runtime.jobmaster.JobMaster at akka://flink/user/jobmanager_287 . 20846 [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.jobmaster.JobMaster - Initializing job Blocking test job (10916cea5ecc0ea53989d755e8699478). 20846 [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.jobmaster.JobMaster - Using restart back off time strategy NoRestartBackoffTimeStrategy for Blocking test job (10916cea5ecc0ea53989d755e8699478). 20847 [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.jobmaster.JobMaster - Running initialization on master for job Blocking test job (10916cea5ecc0ea53989d755e8699478). 20847 [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.jobmaster.JobMaster - Successfully ran initialization on master in 0 ms. 20847 [flink-akka.actor.default-dispatcher-3] DEBUG org.apache.flink.runtime.jobmaster.JobMaster - Adding 1 vertices from job graph Blocking test job (10916cea5ecc0ea53989d755e8699478). 20847 [flink-akka.actor.default-dispatcher-3] DEBUG org.apache.flink.runtime.executiongraph.ExecutionGraph - Attaching 1 topologically sorted vertices to existing job graph with 0 vertices and 0 intermediate results. 20847 [flink-akka.actor.default-dispatcher-3] DEBUG org.apache.flink.runtime.executiongraph.ExecutionGraph - Connecting ExecutionJobVertex 36153b5f02971ac3141ec6a366a00464 (blocking operator) to 0 predecessors. 20847 [flink-akka.actor.default-dispatcher-3] DEBUG org.apache.flink.runtime.jobmaster.JobMaster - Successfully created execution graph from job graph Blocking test job (10916cea5ecc0ea53989d755e8699478). 20847 [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.failover.flip1.RestartPipelinedRegionStrategy - Start building failover regions. 20847 [flink-akka.actor.default-dispatcher-3] DEBUG org.apache.flink.runtime.executiongraph.failover.flip1.RestartPipelinedRegionStrategy - Creating a failover region with 1 vertices. 20847 [flink-akka.actor.default-dispatcher-3] DEBUG org.apache.flink.runtime.executiongraph.failover.flip1.RestartPipelinedRegionStrategy - Creating a failover region with 1 vertices. 20847 [flink-akka.actor.default-dispatcher-3] DEBUG org.apache.flink.runtime.executiongraph.failover.flip1.RestartPipelinedRegionStrategy - Creating a failover region with 1 vertices. 20847 [flink-akka.actor.default-dispatcher-3] DEBUG org.apache.flink.runtime.executiongraph.failover.flip1.RestartPipelinedRegionStrategy - Creating a failover region with 1 vertices. 20847 [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.failover.flip1.RestartPipelinedRegionStrategy - Created 4 failover regions. 20847 [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.jobmaster.JobMaster - Using failover strategy org.apache.flink.runtime.executiongraph.failover.flip1.RestartPipelinedRegionStrategy@4a0a5390 for Blocking test job (10916cea5ecc0ea53989d755e8699478). 20847 [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.highavailability.nonha.embedded.EmbeddedLeaderService - Proposing leadership to contender akka://flink/user/jobmanager_287 20847 [pool-1-thread-1] INFO org.apache.flink.runtime.jobmaster.JobManagerRunnerImpl - JobManager runner for job Blocking test job (10916cea5ecc0ea53989d755e8699478) was granted leadership with session id 39ab559a-76e6-408e-9da0-f411625eeda5 at akka://flink/user/jobmanager_287. 20847 [Time-limited test] INFO org.apache.flink.runtime.highavailability.nonha.embedded.EmbeddedLeaderService - Revoking leadership of org.apache.flink.runtime.dispatcher.runner.DefaultDispatcherRunner@4cfbe5ca. 20847 [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.jobmaster.JobMaster - Starting execution of job Blocking test job (10916cea5ecc0ea53989d755e8699478) under job master id 9da0f411625eeda539ab559a76e6408e. 20847 [pool-1-thread-1] INFO org.apache.flink.runtime.dispatcher.runner.SessionDispatcherLeaderProcess - Stopping SessionDispatcherLeaderProcess. 20847 [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.jobmaster.JobMaster - Starting scheduling with scheduling strategy [org.apache.flink.runtime.scheduler.strategy.LazyFromSourcesSchedulingStrategy] 20847 [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Job Blocking test job (10916cea5ecc0ea53989d755e8699478) switched from state CREATED to RUNNING. 20847 [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopping dispatcher akka://flink/user/dispatcherd5f8446f-b44d-4bcd-88b3-65105c1c6ca0. 20847 [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopping all currently running jobs of dispatcher akka://flink/user/dispatcherd5f8446f-b44d-4bcd-88b3-65105c1c6ca0. 20847 [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - blocking operator (1/4) (daeaeda48899ddb597bf2249739d21a2) switched from CREATED to SCHEDULED. 20847 [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - blocking operator (2/4) (eca90f0e31fe3e10041541b602d07a07) switched from CREATED to SCHEDULED. 20847 [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - blocking operator (3/4) (411f597cd777705a3199770a2d0a826b) switched from CREATED to SCHEDULED. 20847 [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - blocking operator (4/4) (93d481fc25c6b31bac3804298a5aaae2) switched from CREATED to SCHEDULED. 20847 [flink-akka.actor.default-dispatcher-3] DEBUG org.apache.flink.runtime.scheduler.DefaultExecutionSlotAllocator - Allocate slot with id SlotRequestId{4f37fb217e29615eb4d23a5c8d0d35da} for execution 36153b5f02971ac3141ec6a366a00464_0 20847 [flink-akka.actor.default-dispatcher-3] DEBUG org.apache.flink.runtime.jobmaster.slotpool.SchedulerImpl - Received slot request [SlotRequestId{4f37fb217e29615eb4d23a5c8d0d35da}] for task: null 20847 [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.jobmaster.slotpool.SlotPoolImpl - Cannot serve slot request, no ResourceManager connected. Adding as pending request [SlotRequestId{4f37fb217e29615eb4d23a5c8d0d35da}] 20847 [flink-akka.actor.default-dispatcher-3] DEBUG org.apache.flink.runtime.scheduler.DefaultExecutionSlotAllocator - Allocate slot with id SlotRequestId{82ae5d4df5fe6fa591e7e62f3eed0027} for execution 36153b5f02971ac3141ec6a366a00464_1 20847 [flink-akka.actor.default-dispatcher-3] DEBUG org.apache.flink.runtime.jobmaster.slotpool.SchedulerImpl - Received slot request [SlotRequestId{82ae5d4df5fe6fa591e7e62f3eed0027}] for task: null 20847 [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.jobmaster.slotpool.SlotPoolImpl - Cannot serve slot request, no ResourceManager connected. Adding as pending request [SlotRequestId{82ae5d4df5fe6fa591e7e62f3eed0027}] 20847 [flink-akka.actor.default-dispatcher-3] DEBUG org.apache.flink.runtime.scheduler.DefaultExecutionSlotAllocator - Allocate slot with id SlotRequestId{5bc58f32a012441c51111596eb51365c} for execution 36153b5f02971ac3141ec6a366a00464_2 20847 [flink-akka.actor.default-dispatcher-3] DEBUG org.apache.flink.runtime.jobmaster.slotpool.SchedulerImpl - Received slot request [SlotRequestId{5bc58f32a012441c51111596eb51365c}] for task: null 20847 [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.jobmaster.slotpool.SlotPoolImpl - Cannot serve slot request, no ResourceManager connected. Adding as pending request [SlotRequestId{5bc58f32a012441c51111596eb51365c}] 20847 [flink-akka.actor.default-dispatcher-3] DEBUG org.apache.flink.runtime.scheduler.DefaultExecutionSlotAllocator - Allocate slot with id SlotRequestId{e0647296e4d35e129acb9c5bb6c08b5c} for execution 36153b5f02971ac3141ec6a366a00464_3 20847 [flink-akka.actor.default-dispatcher-3] DEBUG org.apache.flink.runtime.jobmaster.slotpool.SchedulerImpl - Received slot request [SlotRequestId{e0647296e4d35e129acb9c5bb6c08b5c}] for task: null 20847 [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.jobmaster.slotpool.SlotPoolImpl - Cannot serve slot request, no ResourceManager connected. Adding as pending request [SlotRequestId{e0647296e4d35e129acb9c5bb6c08b5c}] 20847 [jobmanager-future-thread-1] INFO org.apache.flink.runtime.highavailability.nonha.embedded.EmbeddedLeaderService - Received confirmation of leadership for leader akka://flink/user/jobmanager_287 , session=39ab559a-76e6-408e-9da0-f411625eeda5 20847 [flink-akka.actor.default-dispatcher-3] DEBUG org.apache.flink.runtime.jobmaster.JobMaster - Trigger heartbeat request. 20847 [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.jobmaster.JobMaster - Connecting to ResourceManager akka://flink/user/resourcemanager9fa41f3a-7bd4-4f72-ae07-76b75499c88d(addd3d7aa17fd083e73f31a7c45f4328) 20847 [flink-akka.actor.default-dispatcher-3] DEBUG org.apache.flink.runtime.rpc.akka.AkkaRpcService - Try to connect to remote RPC endpoint with address akka://flink/user/resourcemanager9fa41f3a-7bd4-4f72-ae07-76b75499c88d. Returning a org.apache.flink.runtime.resourcemanager.ResourceManagerGateway gateway. 20848 [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.jobmaster.JobMaster - Stopping the JobMaster for job Blocking test job(10916cea5ecc0ea53989d755e8699478). 20848 [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.jobmaster.JobMaster - Resolved ResourceManager address, beginning registration 20848 [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.jobmaster.JobMaster - Registration at ResourceManager attempt 1 (timeout=100ms) 20848 [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Job Blocking test job (10916cea5ecc0ea53989d755e8699478) switched from state RUNNING to SUSPENDED. org.apache.flink.util.FlinkException: JobManager is shutting down. at org.apache.flink.runtime.jobmaster.JobMaster.onStop(JobMaster.java:350) at org.apache.flink.runtime.rpc.RpcEndpoint.internalCallOnStop(RpcEndpoint.java:218) at org.apache.flink.runtime.rpc.akka.AkkaRpcActor$StartedState.terminate(AkkaRpcActor.java:509) at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleControlMessage(AkkaRpcActor.java:175) at akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:26) at akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:21) at scala.PartialFunction$class.applyOrElse(PartialFunction.scala:123) at akka.japi.pf.UnitCaseStatement.applyOrElse(CaseStatements.scala:21) at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:170) at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:171) at akka.actor.Actor$class.aroundReceive(Actor.scala:517) at akka.actor.AbstractActor.aroundReceive(AbstractActor.scala:225) at akka.actor.ActorCell.receiveMessage(ActorCell.scala:592) at akka.actor.ActorCell.invoke(ActorCell.scala:561) at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:258) at akka.dispatch.Mailbox.run(Mailbox.scala:225) at akka.dispatch.Mailbox.exec(Mailbox.scala:235) at akka.dispatch.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260) at akka.dispatch.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339) at akka.dispatch.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979) at akka.dispatch.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107) 20848 [flink-akka.actor.default-dispatcher-2] DEBUG org.apache.flink.runtime.resourcemanager.JobLeaderIdService - Add job 10916cea5ecc0ea53989d755e8699478 to job leader id monitoring. 20848 [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.resourcemanager.StandaloneResourceManager - Registering job manager 9da0f411625eeda539ab559a76e6408e@akka://flink/user/jobmanager_287 for job 10916cea5ecc0ea53989d755e8699478. 20848 [pool-1-thread-1] DEBUG org.apache.flink.runtime.resourcemanager.JobLeaderIdService - Found a new job leader 39ab559a-76e6-408e-9da0-f411625eeda5@akka://flink/user/jobmanager_287. 20848 [flink-akka.actor.default-dispatcher-2] DEBUG org.apache.flink.runtime.rpc.akka.AkkaRpcService - Try to connect to remote RPC endpoint with address akka://flink/user/jobmanager_287. Returning a org.apache.flink.runtime.jobmaster.JobMasterGateway gateway. 20848 [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - blocking operator (1/4) (daeaeda48899ddb597bf2249739d21a2) switched from SCHEDULED to CANCELING. 20848 [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - blocking operator (1/4) (daeaeda48899ddb597bf2249739d21a2) switched from CANCELING to CANCELED. 20848 [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Discarding the results produced by task execution daeaeda48899ddb597bf2249739d21a2. 20848 [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - blocking operator (2/4) (eca90f0e31fe3e10041541b602d07a07) switched from SCHEDULED to CANCELING. 20848 [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - blocking operator (2/4) (eca90f0e31fe3e10041541b602d07a07) switched from CANCELING to CANCELED. 20848 [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Discarding the results produced by task execution eca90f0e31fe3e10041541b602d07a07. 20848 [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - blocking operator (3/4) (411f597cd777705a3199770a2d0a826b) switched from SCHEDULED to CANCELING. 20848 [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - blocking operator (3/4) (411f597cd777705a3199770a2d0a826b) switched from CANCELING to CANCELED. 20848 [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Discarding the results produced by task execution 411f597cd777705a3199770a2d0a826b. 20848 [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - blocking operator (4/4) (93d481fc25c6b31bac3804298a5aaae2) switched from SCHEDULED to CANCELING. 20848 [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - blocking operator (4/4) (93d481fc25c6b31bac3804298a5aaae2) switched from CANCELING to CANCELED. 20848 [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Discarding the results produced by task execution 93d481fc25c6b31bac3804298a5aaae2. 20848 [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Job 10916cea5ecc0ea53989d755e8699478 has been suspended. 20848 [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.jobmaster.slotpool.SlotPoolImpl - Suspending SlotPool. 20848 [jobmanager-future-thread-1] DEBUG org.apache.flink.runtime.jobmaster.JobMaster - Retrying registration towards akka://flink/user/resourcemanager9fa41f3a-7bd4-4f72-ae07-76b75499c88d was cancelled. 20848 [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.jobmaster.slotpool.SlotPoolImpl - Stopping SlotPool. 20848 [pool-1-thread-1] DEBUG org.apache.flink.runtime.resourcemanager.JobLeaderIdService - Found a new job leader null@null. 20848 [flink-akka.actor.default-dispatcher-4] DEBUG org.apache.flink.runtime.resourcemanager.StandaloneResourceManager - Discard job leader lost leadership for outdated leader 9da0f411625eeda539ab559a76e6408e for job 10916cea5ecc0ea53989d755e8699478. 20848 [flink-akka.actor.default-dispatcher-4] DEBUG org.apache.flink.runtime.dispatcher.StandaloneDispatcher - There is a newer JobManagerRunner for the job 10916cea5ecc0ea53989d755e8699478. 20848 [Time-limited test] INFO org.apache.flink.runtime.highavailability.nonha.embedded.EmbeddedLeaderService - Proposing leadership to contender LeaderContender: DefaultDispatcherRunner 20848 [pool-1-thread-1] DEBUG org.apache.flink.runtime.dispatcher.runner.DefaultDispatcherRunner - Create new DispatcherLeaderProcess with leader session id 73495bcd-e324-4d15-8b41-863bfb3cfbdc. 20848 [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.rest.handler.legacy.backpressure.BackPressureRequestCoordinator - Shutting down back pressure request coordinator. 20848 [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopped dispatcher akka://flink/user/dispatcherd5f8446f-b44d-4bcd-88b3-65105c1c6ca0. 20848 [flink-akka.actor.default-dispatcher-4] DEBUG org.apache.flink.runtime.resourcemanager.StandaloneResourceManager - Registration of job manager 9da0f411625eeda539ab559a76e6408e@akka://flink/user/jobmanager_287 failed. java.util.concurrent.CompletionException: org.apache.flink.runtime.rpc.exceptions.RpcConnectionException: Could not connect to rpc endpoint under address akka://flink/user/jobmanager_287. at org.apache.flink.runtime.rpc.akka.AkkaRpcService.lambda$connectInternal$6(AkkaRpcService.java:452) at java.base/java.util.concurrent.CompletableFuture$UniApply.tryFire(CompletableFuture.java:642) at java.base/java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:506) at java.base/java.util.concurrent.CompletableFuture.complete(CompletableFuture.java:2073) at org.apache.flink.runtime.concurrent.FutureUtils$1.onComplete(FutureUtils.java:874) at akka.dispatch.OnComplete.internal(Future.scala:264) at akka.dispatch.OnComplete.internal(Future.scala:261) at akka.dispatch.japi$CallbackBridge.apply(Future.scala:191) at akka.dispatch.japi$CallbackBridge.apply(Future.scala:188) at scala.concurrent.impl.CallbackRunnable.run(Promise.scala:36) at org.apache.flink.runtime.concurrent.Executors$DirectExecutionContext.execute(Executors.java:74) at scala.concurrent.impl.CallbackRunnable.executeWithValue(Promise.scala:44) at scala.concurrent.impl.Promise$DefaultPromise.tryComplete(Promise.scala:252) at scala.concurrent.Promise$class.complete(Promise.scala:55) at scala.concurrent.impl.Promise$DefaultPromise.complete(Promise.scala:157) at scala.concurrent.Future$$anonfun$map$1.apply(Future.scala:237) at scala.concurrent.Future$$anonfun$map$1.apply(Future.scala:237) at scala.concurrent.impl.CallbackRunnable.run(Promise.scala:36) at scala.concurrent.BatchingExecutor$Batch$$anonfun$run$1.processBatch$1(BatchingExecutor.scala:63) at scala.concurrent.BatchingExecutor$Batch$$anonfun$run$1.apply$mcV$sp(BatchingExecutor.scala:78) at scala.concurrent.BatchingExecutor$Batch$$anonfun$run$1.apply(BatchingExecutor.scala:55) at scala.concurrent.BatchingExecutor$Batch$$anonfun$run$1.apply(BatchingExecutor.scala:55) at scala.concurrent.BlockContext$.withBlockContext(BlockContext.scala:72) at scala.concurrent.BatchingExecutor$Batch.run(BatchingExecutor.scala:54) at scala.concurrent.Future$InternalCallbackExecutor$.unbatchedExecute(Future.scala:601) at scala.concurrent.BatchingExecutor$class.execute(BatchingExecutor.scala:106) at scala.concurrent.Future$InternalCallbackExecutor$.execute(Future.scala:599) at scala.concurrent.impl.CallbackRunnable.executeWithValue(Promise.scala:44) at scala.concurrent.impl.Promise$DefaultPromise.tryComplete(Promise.scala:252) at akka.pattern.PromiseActorRef.$bang(AskSupport.scala:572) at akka.actor.EmptyLocalActorRef.specialHandle(ActorRef.scala:551) at akka.actor.DeadLetterActorRef.specialHandle(ActorRef.scala:593) at akka.actor.DeadLetterActorRef.$bang(ActorRef.scala:582) at akka.actor.ActorRef.tell(ActorRef.scala:126) at akka.dispatch.Mailboxes$$anon$1$$anon$2.enqueue(Mailboxes.scala:36) at akka.dispatch.QueueBasedMessageQueue$class.cleanUp(Mailbox.scala:487) at akka.dispatch.UnboundedMailbox$MessageQueue.cleanUp(Mailbox.scala:616) at akka.dispatch.Mailbox.cleanUp(Mailbox.scala:330) at akka.dispatch.MessageDispatcher.unregister(AbstractDispatcher.scala:210) at akka.dispatch.MessageDispatcher.detach(AbstractDispatcher.scala:140) at akka.actor.dungeon.FaultHandling$class.akka$actor$dungeon$FaultHandling$$finishTerminate(FaultHandling.scala:212) at akka.actor.dungeon.FaultHandling$class.terminate(FaultHandling.scala:172) at akka.actor.ActorCell.terminate(ActorCell.scala:429) at akka.actor.ActorCell.invokeAll$1(ActorCell.scala:533) at akka.actor.ActorCell.systemInvoke(ActorCell.scala:549) at akka.dispatch.Mailbox.processAllSystemMessages(Mailbox.scala:283) at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:261) at akka.dispatch.Mailbox.run(Mailbox.scala:225) at akka.dispatch.Mailbox.exec(Mailbox.scala:235) at akka.dispatch.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260) at akka.dispatch.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339) at akka.dispatch.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979) at akka.dispatch.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107) Caused by: org.apache.flink.runtime.rpc.exceptions.RpcConnectionException: Could not connect to rpc endpoint under address akka://flink/user/jobmanager_287. ... 53 more 20848 [mini-cluster-io-thread-2] INFO org.apache.flink.runtime.dispatcher.runner.SessionDispatcherLeaderProcess - Start SessionDispatcherLeaderProcess. 20849 [mini-cluster-io-thread-3] INFO org.apache.flink.runtime.dispatcher.runner.SessionDispatcherLeaderProcess - Recover all persisted job graphs. 20849 [mini-cluster-io-thread-3] INFO org.apache.flink.runtime.dispatcher.runner.SessionDispatcherLeaderProcess - Successfully recovered 0 persisted job graphs. 20849 [mini-cluster-io-thread-3] INFO org.apache.flink.runtime.rpc.akka.AkkaRpcService - Starting RPC endpoint for org.apache.flink.runtime.dispatcher.StandaloneDispatcher at akka://flink/user/dispatcher8411eb0e-aa2f-41c7-96f1-ffa17a27da03 . 20849 [mini-cluster-io-thread-3] INFO org.apache.flink.runtime.highavailability.nonha.embedded.EmbeddedLeaderService - Received confirmation of leadership for leader akka://flink/user/dispatcher8411eb0e-aa2f-41c7-96f1-ffa17a27da03 , session=73495bcd-e324-4d15-8b41-863bfb3cfbdc 20849 [pool-1-thread-1] DEBUG org.apache.flink.runtime.rpc.akka.AkkaRpcService - Try to connect to remote RPC endpoint with address akka://flink/user/dispatcher8411eb0e-aa2f-41c7-96f1-ffa17a27da03. Returning a org.apache.flink.runtime.dispatcher.DispatcherGateway gateway. 20849 [pool-1-thread-1] DEBUG org.apache.flink.runtime.rpc.akka.AkkaRpcService - Try to connect to remote RPC endpoint with address akka://flink/user/dispatcher8411eb0e-aa2f-41c7-96f1-ffa17a27da03. Returning a org.apache.flink.runtime.dispatcher.DispatcherGateway gateway. 20849 [pool-1-thread-1] DEBUG org.apache.flink.runtime.rpc.akka.AkkaRpcService - Try to connect to remote RPC endpoint with address akka://flink/user/dispatcher8411eb0e-aa2f-41c7-96f1-ffa17a27da03. Returning a org.apache.flink.runtime.dispatcher.DispatcherGateway gateway. 20849 [pool-1-thread-1] DEBUG org.apache.flink.runtime.rpc.akka.AkkaRpcService - Try to connect to remote RPC endpoint with address akka://flink/user/dispatcher8411eb0e-aa2f-41c7-96f1-ffa17a27da03. Returning a org.apache.flink.runtime.dispatcher.DispatcherGateway gateway. 20849 [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Received JobGraph submission 10916cea5ecc0ea53989d755e8699478 (Blocking test job). 20849 [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Submitting job 10916cea5ecc0ea53989d755e8699478 (Blocking test job). 20850 [flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.rpc.akka.AkkaRpcService - Starting RPC endpoint for org.apache.flink.runtime.jobmaster.JobMaster at akka://flink/user/jobmanager_288 . 20850 [flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.jobmaster.JobMaster - Initializing job Blocking test job (10916cea5ecc0ea53989d755e8699478). 20850 [flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.jobmaster.JobMaster - Using restart back off time strategy NoRestartBackoffTimeStrategy for Blocking test job (10916cea5ecc0ea53989d755e8699478). 20850 [flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.jobmaster.JobMaster - Running initialization on master for job Blocking test job (10916cea5ecc0ea53989d755e8699478). 20850 [flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.jobmaster.JobMaster - Successfully ran initialization on master in 0 ms. 20850 [flink-akka.actor.default-dispatcher-5] DEBUG org.apache.flink.runtime.jobmaster.JobMaster - Adding 1 vertices from job graph Blocking test job (10916cea5ecc0ea53989d755e8699478). 20850 [flink-akka.actor.default-dispatcher-5] DEBUG org.apache.flink.runtime.executiongraph.ExecutionGraph - Attaching 1 topologically sorted vertices to existing job graph with 0 vertices and 0 intermediate results. 20850 [flink-akka.actor.default-dispatcher-5] DEBUG org.apache.flink.runtime.executiongraph.ExecutionGraph - Connecting ExecutionJobVertex 36153b5f02971ac3141ec6a366a00464 (blocking operator) to 0 predecessors. 20850 [flink-akka.actor.default-dispatcher-5] DEBUG org.apache.flink.runtime.jobmaster.JobMaster - Successfully created execution graph from job graph Blocking test job (10916cea5ecc0ea53989d755e8699478). 20850 [flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.executiongraph.failover.flip1.RestartPipelinedRegionStrategy - Start building failover regions. 20850 [flink-akka.actor.default-dispatcher-5] DEBUG org.apache.flink.runtime.executiongraph.failover.flip1.RestartPipelinedRegionStrategy - Creating a failover region with 1 vertices. 20850 [flink-akka.actor.default-dispatcher-5] DEBUG org.apache.flink.runtime.executiongraph.failover.flip1.RestartPipelinedRegionStrategy - Creating a failover region with 1 vertices. 20850 [flink-akka.actor.default-dispatcher-5] DEBUG org.apache.flink.runtime.executiongraph.failover.flip1.RestartPipelinedRegionStrategy - Creating a failover region with 1 vertices. 20850 [flink-akka.actor.default-dispatcher-5] DEBUG org.apache.flink.runtime.executiongraph.failover.flip1.RestartPipelinedRegionStrategy - Creating a failover region with 1 vertices. 20850 [flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.executiongraph.failover.flip1.RestartPipelinedRegionStrategy - Created 4 failover regions. 20850 [flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.jobmaster.JobMaster - Using failover strategy org.apache.flink.runtime.executiongraph.failover.flip1.RestartPipelinedRegionStrategy@278dfbf for Blocking test job (10916cea5ecc0ea53989d755e8699478). 20850 [flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.highavailability.nonha.embedded.EmbeddedLeaderService - Proposing leadership to contender akka://flink/user/jobmanager_288 20850 [pool-1-thread-1] INFO org.apache.flink.runtime.jobmaster.JobManagerRunnerImpl - JobManager runner for job Blocking test job (10916cea5ecc0ea53989d755e8699478) was granted leadership with session id feafc884-4fbd-49e0-b35a-21d553ed03da at akka://flink/user/jobmanager_288. 20850 [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.jobmaster.JobMaster - Starting execution of job Blocking test job (10916cea5ecc0ea53989d755e8699478) under job master id b35a21d553ed03dafeafc8844fbd49e0. 20850 [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.jobmaster.JobMaster - Starting scheduling with scheduling strategy [org.apache.flink.runtime.scheduler.strategy.LazyFromSourcesSchedulingStrategy] 20850 [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Job Blocking test job (10916cea5ecc0ea53989d755e8699478) switched from state CREATED to RUNNING. 20850 [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - blocking operator (1/4) (da2cc6b05eb054ba81678a2d47c2ad1a) switched from CREATED to SCHEDULED. 20850 [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - blocking operator (2/4) (dd6940b933e1b6373ee014cec8e7cbe9) switched from CREATED to SCHEDULED. 20851 [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - blocking operator (3/4) (20f73631beab206c03673a81d520638e) switched from CREATED to SCHEDULED. 20851 [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - blocking operator (4/4) (bd0fbc82bd04edcdeeae48ac85259cef) switched from CREATED to SCHEDULED. 20851 [flink-akka.actor.default-dispatcher-3] DEBUG org.apache.flink.runtime.scheduler.DefaultExecutionSlotAllocator - Allocate slot with id SlotRequestId{b8ff29fdfdb95ee6656d681fac7ce8fa} for execution 36153b5f02971ac3141ec6a366a00464_0 20851 [flink-akka.actor.default-dispatcher-3] DEBUG org.apache.flink.runtime.jobmaster.slotpool.SchedulerImpl - Received slot request [SlotRequestId{b8ff29fdfdb95ee6656d681fac7ce8fa}] for task: null 20851 [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.jobmaster.slotpool.SlotPoolImpl - Cannot serve slot request, no ResourceManager connected. Adding as pending request [SlotRequestId{b8ff29fdfdb95ee6656d681fac7ce8fa}] 20851 [flink-akka.actor.default-dispatcher-3] DEBUG org.apache.flink.runtime.scheduler.DefaultExecutionSlotAllocator - Allocate slot with id SlotRequestId{dbcbd0676ca49c8fea8f4532c34eeffd} for execution 36153b5f02971ac3141ec6a366a00464_1 20851 [flink-akka.actor.default-dispatcher-3] DEBUG org.apache.flink.runtime.jobmaster.slotpool.SchedulerImpl - Received slot request [SlotRequestId{dbcbd0676ca49c8fea8f4532c34eeffd}] for task: null 20851 [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.jobmaster.slotpool.SlotPoolImpl - Cannot serve slot request, no ResourceManager connected. Adding as pending request [SlotRequestId{dbcbd0676ca49c8fea8f4532c34eeffd}] 20851 [flink-akka.actor.default-dispatcher-3] DEBUG org.apache.flink.runtime.scheduler.DefaultExecutionSlotAllocator - Allocate slot with id SlotRequestId{d12f5bb630b6295e60ac962e5eeda235} for execution 36153b5f02971ac3141ec6a366a00464_2 20851 [flink-akka.actor.default-dispatcher-3] DEBUG org.apache.flink.runtime.jobmaster.slotpool.SchedulerImpl - Received slot request [SlotRequestId{d12f5bb630b6295e60ac962e5eeda235}] for task: null 20851 [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.jobmaster.slotpool.SlotPoolImpl - Cannot serve slot request, no ResourceManager connected. Adding as pending request [SlotRequestId{d12f5bb630b6295e60ac962e5eeda235}] 20851 [flink-akka.actor.default-dispatcher-3] DEBUG org.apache.flink.runtime.scheduler.DefaultExecutionSlotAllocator - Allocate slot with id SlotRequestId{8e00d9199f13765ccf4f23ea98523da4} for execution 36153b5f02971ac3141ec6a366a00464_3 20851 [flink-akka.actor.default-dispatcher-3] DEBUG org.apache.flink.runtime.jobmaster.slotpool.SchedulerImpl - Received slot request [SlotRequestId{8e00d9199f13765ccf4f23ea98523da4}] for task: null 20851 [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.jobmaster.slotpool.SlotPoolImpl - Cannot serve slot request, no ResourceManager connected. Adding as pending request [SlotRequestId{8e00d9199f13765ccf4f23ea98523da4}] 20851 [flink-akka.actor.default-dispatcher-3] DEBUG org.apache.flink.runtime.jobmaster.JobMaster - Trigger heartbeat request. 20851 [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.jobmaster.JobMaster - Connecting to ResourceManager akka://flink/user/resourcemanager9fa41f3a-7bd4-4f72-ae07-76b75499c88d(addd3d7aa17fd083e73f31a7c45f4328) 20851 [flink-akka.actor.default-dispatcher-3] DEBUG org.apache.flink.runtime.rpc.akka.AkkaRpcService - Try to connect to remote RPC endpoint with address akka://flink/user/resourcemanager9fa41f3a-7bd4-4f72-ae07-76b75499c88d. Returning a org.apache.flink.runtime.resourcemanager.ResourceManagerGateway gateway. 20851 [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.jobmaster.JobMaster - Resolved ResourceManager address, beginning registration 20851 [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.jobmaster.JobMaster - Registration at ResourceManager attempt 1 (timeout=100ms) 20851 [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.resourcemanager.StandaloneResourceManager - Registering job manager b35a21d553ed03dafeafc8844fbd49e0@akka://flink/user/jobmanager_288 for job 10916cea5ecc0ea53989d755e8699478. 20851 [flink-akka.actor.default-dispatcher-3] DEBUG org.apache.flink.runtime.rpc.akka.AkkaRpcService - Try to connect to remote RPC endpoint with address akka://flink/user/jobmanager_288. Returning a org.apache.flink.runtime.jobmaster.JobMasterGateway gateway. 20851 [jobmanager-future-thread-2] INFO org.apache.flink.runtime.highavailability.nonha.embedded.EmbeddedLeaderService - Received confirmation of leadership for leader akka://flink/user/jobmanager_288 , session=feafc884-4fbd-49e0-b35a-21d553ed03da 20851 [pool-1-thread-1] DEBUG org.apache.flink.runtime.resourcemanager.JobLeaderIdService - Found a new job leader feafc884-4fbd-49e0-b35a-21d553ed03da@akka://flink/user/jobmanager_288. 20851 [flink-akka.actor.default-dispatcher-4] DEBUG org.apache.flink.runtime.resourcemanager.StandaloneResourceManager - The leading JobMaster id null did not match the received JobMaster id b35a21d553ed03dafeafc8844fbd49e0. This indicates that a JobMaster leader change has happened. 20851 [flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.jobmaster.JobMaster - Registration at ResourceManager was declined: The leading JobMaster id null did not match the received JobMaster id b35a21d553ed03dafeafc8844fbd49e0. This indicates that a JobMaster leader change has happened. 20851 [flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.jobmaster.JobMaster - Pausing and re-attempting registration in 30000 ms {code} FYI [~trohrmann] -- This message was sent by Atlassian Jira (v8.3.4#803005) |
«
Return to (DEPRECATED) Apache Flink Mailing List archive.
|
1 view|%1 views
| Free forum by Nabble | Edit this page |