[
https://issues.apache.org/jira/browse/FLINK-10260?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Till Rohrmann resolved FLINK-10260.
-----------------------------------
Resolution: Fixed
Fixed via
1.7.0: 542e8cc22290984b4b2e32577430ceb82dd82fde
1.6.2: 23221f97f3462031fa5374803df1a1d57634ff8d
1.5.5: 8dee8625502a828a303b8ec4180ab00b7e794334
> Confusing log during TaskManager registration
> ---------------------------------------------
>
> Key: FLINK-10260
> URL: https://issues.apache.org/jira/browse/FLINK-10260
> Project: Flink
> Issue Type: Bug
> Components: ResourceManager
> Affects Versions: 1.5.3, 1.6.0, 1.7.0
> Reporter: Stephan Ewen
> Assignee: Andrey Zagrebin
> Priority: Major
> Labels: pull-request-available
> Fix For: 1.7.0, 1.6.2, 1.5.5
>
>
> During startup, when TaskManagers register, I see a lot of confusing log
> lines.
> The below case happened during startup of a cloud setup where TaskManagers
> took a varying amount of time to start and might have started before the
> JobManager
> {code}
> -- Logs begin at Thu 2018-08-30 14:51:58 UTC, end at Thu 2018-08-30 14:55:39
> UTC. --
> Aug 30 14:52:52 flink-belgium-1 systemd[1]: Started flink-jobmanager.service.
> -- Subject: Unit flink-jobmanager.service has finished start-up
> -- Defined-By: systemd
> -- Support: http://www.ubuntu.com/support
> --
> -- Unit flink-jobmanager.service has finished starting up.
> --
> -- The start-up result is RESULT.
> Aug 30 14:52:52 flink-belgium-1 jobmanager.sh[5416]: used deprecated key
> `jobmanager.heap.mb`, please replace with key `jobmanager.heap.size`
> Aug 30 14:52:53 flink-belgium-1 jobmanager.sh[5416]: Starting
> standalonesession as a console application on host flink-belgium-1.
> Aug 30 14:52:53 flink-belgium-1 jobmanager.sh[5416]: 2018-08-30 14:52:53,221
> INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint -
> --------------------------------------------------------------------------------
> Aug 30 14:52:53 flink-belgium-1 jobmanager.sh[5416]: 2018-08-30 14:52:53,222
> INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint -
> Starting StandaloneSessionClusterEntrypoint (Version: 1.6.0, Rev:ff472b4,
> Date:07.08.2018 @ 13:31:13 UTC)
> Aug 30 14:52:53 flink-belgium-1 jobmanager.sh[5416]: 2018-08-30 14:52:53,222
> INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint - OS
> current user: flink
> Aug 30 14:52:53 flink-belgium-1 jobmanager.sh[5416]: 2018-08-30 14:52:53,718
> WARN org.apache.hadoop.util.NativeCodeLoader - Unable
> to load native-hadoop library for your platform... using builtin-java classes
> where applicable
> Aug 30 14:52:53 flink-belgium-1 jobmanager.sh[5416]: 2018-08-30 14:52:53,847
> INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint -
> Current Hadoop/Kerberos user: flink
> Aug 30 14:52:53 flink-belgium-1 jobmanager.sh[5416]: 2018-08-30 14:52:53,848
> INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint - JVM:
> OpenJDK 64-Bit Server VM - Oracle Corporation - 1.8/25.181-b13
> Aug 30 14:52:53 flink-belgium-1 jobmanager.sh[5416]: 2018-08-30 14:52:53,848
> INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint -
> Maximum heap size: 1963 MiBytes
> Aug 30 14:52:53 flink-belgium-1 jobmanager.sh[5416]: 2018-08-30 14:52:53,848
> INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint -
> JAVA_HOME: (not set)
> Aug 30 14:52:53 flink-belgium-1 jobmanager.sh[5416]: 2018-08-30 14:52:53,853
> INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint - Hadoop
> version: 2.8.3
> Aug 30 14:52:53 flink-belgium-1 jobmanager.sh[5416]: 2018-08-30 14:52:53,853
> INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint - JVM
> Options:
> Aug 30 14:52:53 flink-belgium-1 jobmanager.sh[5416]: 2018-08-30 14:52:53,853
> INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint -
> -Xms2048m
> Aug 30 14:52:53 flink-belgium-1 jobmanager.sh[5416]: 2018-08-30 14:52:53,853
> INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint -
> -Xmx2048m
> Aug 30 14:52:53 flink-belgium-1 jobmanager.sh[5416]: 2018-08-30 14:52:53,853
> INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint -
> -Dlog4j.configuration=file:/opt/flink/conf/log4j-console.properties
> Aug 30 14:52:53 flink-belgium-1 jobmanager.sh[5416]: 2018-08-30 14:52:53,853
> INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint -
> -Dlogback.configurationFile=file:/opt/flink/conf/logback-console.xml
> Aug 30 14:52:53 flink-belgium-1 jobmanager.sh[5416]: 2018-08-30 14:52:53,854
> INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint -
> Program Arguments:
> Aug 30 14:52:53 flink-belgium-1 jobmanager.sh[5416]: 2018-08-30 14:52:53,854
> INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint -
> --configDir
> Aug 30 14:52:53 flink-belgium-1 jobmanager.sh[5416]: 2018-08-30 14:52:53,854
> INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint -
> /opt/flink/conf
> Aug 30 14:52:53 flink-belgium-1 jobmanager.sh[5416]: 2018-08-30 14:52:53,854
> INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint -
> --executionMode
> Aug 30 14:52:53 flink-belgium-1 jobmanager.sh[5416]: 2018-08-30 14:52:53,855
> INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint -
> cluster
> Aug 30 14:52:53 flink-belgium-1 jobmanager.sh[5416]: 2018-08-30 14:52:53,855
> INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint -
> Classpath:
> /opt/flink/lib/flink-python_2.11-1.6.0.jar:/opt/flink/lib/flink-shaded-hadoop2-uber-1.6.0.jar:/opt/flink/lib/gcs-connector.jar:/opt/flink/lib/log4j-1.2.17.jar:/opt/flink/lib/slf4j-log4j12-1.7.7.jar:/opt/flink/lib/flink-dist_2.11-1.6.0.jar:::
> Aug 30 14:52:53 flink-belgium-1 jobmanager.sh[5416]: 2018-08-30 14:52:53,855
> INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint -
> --------------------------------------------------------------------------------
> Aug 30 14:52:53 flink-belgium-1 jobmanager.sh[5416]: 2018-08-30 14:52:53,856
> INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint -
> Registered UNIX signal handlers for [TERM, HUP, INT]
> Aug 30 14:52:53 flink-belgium-1 jobmanager.sh[5416]: 2018-08-30 14:52:53,867
> INFO org.apache.flink.configuration.GlobalConfiguration - Loading
> configuration property: jobmanager.rpc.address, 10.240.10.1
> Aug 30 14:52:53 flink-belgium-1 jobmanager.sh[5416]: 2018-08-30 14:52:53,868
> INFO org.apache.flink.configuration.GlobalConfiguration - Loading
> configuration property: jobmanager.heap.mb, 2048
> Aug 30 14:52:53 flink-belgium-1 jobmanager.sh[5416]: 2018-08-30 14:52:53,868
> INFO org.apache.flink.configuration.GlobalConfiguration - Loading
> configuration property: taskmanager.heap.mb, 10240
> Aug 30 14:52:53 flink-belgium-1 jobmanager.sh[5416]: 2018-08-30 14:52:53,868
> INFO org.apache.flink.configuration.GlobalConfiguration - Loading
> configuration property: taskmanager.numberOfTaskSlots, 1
> Aug 30 14:52:53 flink-belgium-1 jobmanager.sh[5416]: 2018-08-30 14:52:53,868
> INFO org.apache.flink.configuration.GlobalConfiguration - Loading
> configuration property: taskmanager.network.netty.server.numThreads, 4
> Aug 30 14:52:53 flink-belgium-1 jobmanager.sh[5416]: 2018-08-30 14:52:53,868
> INFO org.apache.flink.configuration.GlobalConfiguration - Loading
> configuration property: taskmanager.network.netty.client.numThreads, 4
> Aug 30 14:52:53 flink-belgium-1 jobmanager.sh[5416]: 2018-08-30 14:52:53,869
> INFO org.apache.flink.configuration.GlobalConfiguration - Loading
> configuration property: state.backend, filesystem
> Aug 30 14:52:53 flink-belgium-1 jobmanager.sh[5416]: 2018-08-30 14:52:53,869
> INFO org.apache.flink.configuration.GlobalConfiguration - Loading
> configuration property: state.checkpoints.dir,
> gs://da-ffb2018-demo-eu/checkpoints/
> Aug 30 14:52:53 flink-belgium-1 jobmanager.sh[5416]: 2018-08-30 14:52:53,869
> INFO org.apache.flink.configuration.GlobalConfiguration - Loading
> configuration property: state.savepoints.dir,
> gs://da-ffb2018-demo-eu/savepoints/
> Aug 30 14:52:53 flink-belgium-1 jobmanager.sh[5416]: 2018-08-30 14:52:53,869
> INFO org.apache.flink.configuration.GlobalConfiguration - Loading
> configuration property: state.backend.incremental, true
> Aug 30 14:52:53 flink-belgium-1 jobmanager.sh[5416]: 2018-08-30 14:52:53,890
> INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint -
> Starting StandaloneSessionClusterEntrypoint.
> Aug 30 14:52:53 flink-belgium-1 jobmanager.sh[5416]: 2018-08-30 14:52:53,890
> INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint - Install
> default filesystem.
> Aug 30 14:52:53 flink-belgium-1 jobmanager.sh[5416]: 2018-08-30 14:52:53,915
> INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint - Install
> security context.
> Aug 30 14:52:53 flink-belgium-1 jobmanager.sh[5416]: 2018-08-30 14:52:53,981
> INFO org.apache.flink.runtime.security.modules.HadoopModule - Hadoop
> user set to flink (auth:SIMPLE)
> Aug 30 14:52:54 flink-belgium-1 jobmanager.sh[5416]: 2018-08-30 14:52:54,002
> INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint -
> Initializing cluster services.
> Aug 30 14:52:54 flink-belgium-1 jobmanager.sh[5416]: 2018-08-30 14:52:54,034
> INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint - Trying
> to start actor system at 10.240.10.1:6123
> Aug 30 14:52:54 flink-belgium-1 jobmanager.sh[5416]: 2018-08-30 14:52:54,747
> INFO akka.event.slf4j.Slf4jLogger -
> Slf4jLogger started
> Aug 30 14:52:54 flink-belgium-1 jobmanager.sh[5416]: 2018-08-30 14:52:54,817
> INFO akka.remote.Remoting -
> Starting remoting
> Aug 30 14:52:55 flink-belgium-1 jobmanager.sh[5416]: 2018-08-30 14:52:55,005
> INFO akka.remote.Remoting -
> Remoting started; listening on addresses :[akka.tcp://flink@10.240.10.1:6123]
> Aug 30 14:52:55 flink-belgium-1 jobmanager.sh[5416]: 2018-08-30 14:52:55,013
> INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint - Actor
> system started at akka.tcp://flink@10.240.10.1:6123
> Aug 30 14:52:55 flink-belgium-1 jobmanager.sh[5416]: 2018-08-30 14:52:55,030
> WARN org.apache.flink.configuration.Configuration - Config
> uses deprecated configuration key 'jobmanager.rpc.address' instead of proper
> key 'rest.address'
> Aug 30 14:52:55 flink-belgium-1 jobmanager.sh[5416]: 2018-08-30 14:52:55,038
> INFO org.apache.flink.runtime.blob.BlobServer - Created
> BLOB server storage directory
> /tmp/blobStore-429b71f8-860b-4ca6-af82-a68c7b6e8d39
> Aug 30 14:52:55 flink-belgium-1 jobmanager.sh[5416]: 2018-08-30 14:52:55,043
> INFO org.apache.flink.runtime.blob.BlobServer - Started
> BLOB server at 0.0.0.0:43871 - max concurrent requests: 50 - max backlog: 1000
> Aug 30 14:52:55 flink-belgium-1 jobmanager.sh[5416]: 2018-08-30 14:52:55,067
> INFO org.apache.flink.runtime.metrics.MetricRegistryImpl - No
> metrics reporter configured, no metrics will be exposed/reported.
> Aug 30 14:52:55 flink-belgium-1 jobmanager.sh[5416]: 2018-08-30 14:52:55,074
> INFO org.apache.flink.runtime.dispatcher.FileArchivedExecutionGraphStore -
> Initializing FileArchivedExecutionGraphStore: Storage directory
> /tmp/executionGraphStore-d4df2e6e-dc94-4b8f-bbda-7bff63ab597c, expiration
> time 3600000, maximum cache size 52428800 bytes.
> Aug 30 14:52:55 flink-belgium-1 jobmanager.sh[5416]: 2018-08-30 14:52:55,113
> INFO org.apache.flink.runtime.blob.TransientBlobCache - Created
> BLOB cache storage directory
> /tmp/blobStore-66ccd208-7869-4fe8-9130-8e2f7f818827
> Aug 30 14:52:55 flink-belgium-1 jobmanager.sh[5416]: 2018-08-30 14:52:55,124
> WARN org.apache.flink.configuration.Configuration - Config
> uses deprecated configuration key 'jobmanager.rpc.address' instead of proper
> key 'rest.address'
> Aug 30 14:52:55 flink-belgium-1 jobmanager.sh[5416]: 2018-08-30 14:52:55,125
> WARN org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Upload
> directory
> /tmp/flink-web-98c9fe64-b2b7-4f4c-8b06-43f72f496b37/flink-web-upload does not
> exist, or has been deleted externally. Previously uploaded files are no
> longer available.
> Aug 30 14:52:55 flink-belgium-1 jobmanager.sh[5416]: 2018-08-30 14:52:55,126
> INFO org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Created
> directory
> /tmp/flink-web-98c9fe64-b2b7-4f4c-8b06-43f72f496b37/flink-web-upload for file
> uploads.
> Aug 30 14:52:55 flink-belgium-1 jobmanager.sh[5416]: 2018-08-30 14:52:55,132
> INFO org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint -
> Starting rest endpoint.
> Aug 30 14:52:55 flink-belgium-1 jobmanager.sh[5416]: 2018-08-30 14:52:55,350
> WARN org.apache.flink.runtime.webmonitor.WebMonitorUtils - Log
> file environment variable 'log.file' is not set.
> Aug 30 14:52:55 flink-belgium-1 jobmanager.sh[5416]: 2018-08-30 14:52:55,351
> WARN org.apache.flink.runtime.webmonitor.WebMonitorUtils -
> JobManager log files are unavailable in the web dashboard. Log file location
> not found in environment variable 'log.file' or configuration key 'Key:
> 'web.log.path' , default: null (deprecated keys: [jobmanager.web.log.path])'.
> Aug 30 14:52:55 flink-belgium-1 jobmanager.sh[5416]: 2018-08-30 14:52:55,629
> INFO org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Rest
> endpoint listening at 10.240.10.1:8081
> Aug 30 14:52:55 flink-belgium-1 jobmanager.sh[5416]: 2018-08-30 14:52:55,630
> INFO org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint -
> http://10.240.10.1:8081 was granted leadership with
> leaderSessionID=00000000-0000-0000-0000-000000000000
> Aug 30 14:52:55 flink-belgium-1 jobmanager.sh[5416]: 2018-08-30 14:52:55,630
> INFO org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Web
> frontend listening at http://10.240.10.1:8081.
> Aug 30 14:52:55 flink-belgium-1 jobmanager.sh[5416]: 2018-08-30 14:52:55,660
> INFO org.apache.flink.runtime.rpc.akka.AkkaRpcService -
> Starting RPC endpoint for
> org.apache.flink.runtime.resourcemanager.StandaloneResourceManager at
> akka://flink/user/resourcemanager .
> Aug 30 14:52:55 flink-belgium-1 jobmanager.sh[5416]: 2018-08-30 14:52:55,828
> INFO org.apache.flink.runtime.rpc.akka.AkkaRpcService -
> Starting RPC endpoint for
> org.apache.flink.runtime.dispatcher.StandaloneDispatcher at
> akka://flink/user/dispatcher .
> Aug 30 14:52:55 flink-belgium-1 jobmanager.sh[5416]: 2018-08-30 14:52:55,857
> INFO org.apache.flink.runtime.resourcemanager.StandaloneResourceManager -
> ResourceManager akka.tcp://flink@10.240.10.1:6123/user/resourcemanager was
> granted leadership with fencing token 00000000000000000000000000000000
> Aug 30 14:52:55 flink-belgium-1 jobmanager.sh[5416]: 2018-08-30 14:52:55,858
> INFO org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager -
> Starting the SlotManager.
> Aug 30 14:52:55 flink-belgium-1 jobmanager.sh[5416]: 2018-08-30 14:52:55,887
> INFO org.apache.flink.runtime.dispatcher.StandaloneDispatcher -
> Dispatcher akka.tcp://flink@10.240.10.1:6123/user/dispatcher was granted
> leadership with fencing token 00000000-0000-0000-0000-000000000000
> Aug 30 14:52:55 flink-belgium-1 jobmanager.sh[5416]: 2018-08-30 14:52:55,888
> INFO org.apache.flink.runtime.dispatcher.StandaloneDispatcher -
> Recovering all persisted jobs.
> Aug 30 14:52:58 flink-belgium-1 jobmanager.sh[5416]: 2018-08-30 14:52:58,197
> INFO org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager -
> Registering TaskManager 9ed8306a68ec8f054fbb652f1052ee14 under
> d35503003e7afe08690e1b3afee59ba9 at the SlotManager.
> Aug 30 14:52:59 flink-belgium-1 jobmanager.sh[5416]: 2018-08-30 14:52:59,722
> INFO org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager -
> Registering TaskManager 6a031b0fff4f35c8bea16aaae48558d8 under
> 23501750b35b0123a2dfd97757f020e0 at the SlotManager.
> Aug 30 14:53:02 flink-belgium-1 jobmanager.sh[5416]: 2018-08-30 14:53:02,229
> INFO org.apache.flink.runtime.resourcemanager.StandaloneResourceManager -
> Replacing old registration of TaskExecutor 64853ecc94e11d09dc8fe8f95ee0ebb1.
> Aug 30 14:53:02 flink-belgium-1 jobmanager.sh[5416]: 2018-08-30 14:53:02,229
> INFO org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager -
> Unregister TaskManager f5c8abad2ce8445857b1dee362ce698d from the SlotManager.
> Aug 30 14:53:02 flink-belgium-1 jobmanager.sh[5416]: 2018-08-30 14:53:02,229
> INFO org.apache.flink.runtime.resourcemanager.StandaloneResourceManager -
> The target with resource ID 64853ecc94e11d09dc8fe8f95ee0ebb1 is already been
> monitored.
> Aug 30 14:53:02 flink-belgium-1 jobmanager.sh[5416]: 2018-08-30 14:53:02,447
> INFO org.apache.flink.runtime.resourcemanager.StandaloneResourceManager -
> Replacing old registration of TaskExecutor 64853ecc94e11d09dc8fe8f95ee0ebb1.
> Aug 30 14:53:02 flink-belgium-1 jobmanager.sh[5416]: 2018-08-30 14:53:02,447
> INFO org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager -
> Unregister TaskManager 72b06a686c4f89083d57d69de8291918 from the SlotManager.
> Aug 30 14:53:02 flink-belgium-1 jobmanager.sh[5416]: 2018-08-30 14:53:02,447
> INFO org.apache.flink.runtime.resourcemanager.StandaloneResourceManager -
> The target with resource ID 64853ecc94e11d09dc8fe8f95ee0ebb1 is already been
> monitored.
> Aug 30 14:53:02 flink-belgium-1 jobmanager.sh[5416]: 2018-08-30 14:53:02,567
> INFO org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager -
> Registering TaskManager 64853ecc94e11d09dc8fe8f95ee0ebb1 under
> 1a113bfe33a9645f515c67f734208cf4 at the SlotManager.
> Aug 30 14:53:02 flink-belgium-1 jobmanager.sh[5416]: 2018-08-30 14:53:02,758
> INFO org.apache.flink.runtime.resourcemanager.StandaloneResourceManager -
> Replacing old registration of TaskExecutor 30d33c937fd7f45075536dd37d1223e0.
> Aug 30 14:53:02 flink-belgium-1 jobmanager.sh[5416]: 2018-08-30 14:53:02,758
> INFO org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager -
> Unregister TaskManager 7af45b318ba62aa5c211e132b081aa15 from the SlotManager.
> Aug 30 14:53:02 flink-belgium-1 jobmanager.sh[5416]: 2018-08-30 14:53:02,758
> INFO org.apache.flink.runtime.resourcemanager.StandaloneResourceManager -
> The target with resource ID 30d33c937fd7f45075536dd37d1223e0 is already been
> monitored.
> Aug 30 14:53:02 flink-belgium-1 jobmanager.sh[5416]: 2018-08-30 14:53:02,970
> INFO org.apache.flink.runtime.resourcemanager.StandaloneResourceManager -
> Replacing old registration of TaskExecutor 30d33c937fd7f45075536dd37d1223e0.
> Aug 30 14:53:02 flink-belgium-1 jobmanager.sh[5416]: 2018-08-30 14:53:02,970
> INFO org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager -
> Unregister TaskManager 4b640779aebcbbd30dbc4a8df6758d9f from the SlotManager.
> Aug 30 14:53:02 flink-belgium-1 jobmanager.sh[5416]: 2018-08-30 14:53:02,970
> INFO org.apache.flink.runtime.resourcemanager.StandaloneResourceManager -
> The target with resource ID 30d33c937fd7f45075536dd37d1223e0 is already been
> monitored.
> Aug 30 14:53:03 flink-belgium-1 jobmanager.sh[5416]: 2018-08-30 14:53:03,090
> INFO org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager -
> Registering TaskManager 30d33c937fd7f45075536dd37d1223e0 under
> c6eb7999faa10569d21b257f38af14df at the SlotManager.
> Aug 30 14:53:12 flink-belgium-1 jobmanager.sh[5416]: 2018-08-30 14:53:12,332
> INFO org.apache.flink.runtime.resourcemanager.StandaloneResourceManager -
> Replacing old registration of TaskExecutor 94905ed07a84801aae84b8829c9127a9.
> Aug 30 14:53:12 flink-belgium-1 jobmanager.sh[5416]: 2018-08-30 14:53:12,332
> INFO org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager -
> Unregister TaskManager b90efe8dcfc04d7e2e395c3fffd4707e from the SlotManager.
> Aug 30 14:53:12 flink-belgium-1 jobmanager.sh[5416]: 2018-08-30 14:53:12,332
> INFO org.apache.flink.runtime.resourcemanager.StandaloneResourceManager -
> The target with resource ID 94905ed07a84801aae84b8829c9127a9 is already been
> monitored.
> Aug 30 14:53:12 flink-belgium-1 jobmanager.sh[5416]: 2018-08-30 14:53:12,474
> INFO org.apache.flink.runtime.resourcemanager.StandaloneResourceManager -
> Replacing old registration of TaskExecutor 1fb9586b081ae447a1b6980d1ab3db21.
> Aug 30 14:53:12 flink-belgium-1 jobmanager.sh[5416]: 2018-08-30 14:53:12,474
> INFO org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager -
> Unregister TaskManager cbf1e709c151cfbdf8e1e0ab2ba8aa39 from the SlotManager.
> Aug 30 14:53:12 flink-belgium-1 jobmanager.sh[5416]: 2018-08-30 14:53:12,474
> INFO org.apache.flink.runtime.resourcemanager.StandaloneResourceManager -
> The target with resource ID 1fb9586b081ae447a1b6980d1ab3db21 is already been
> monitored.
> Aug 30 14:53:12 flink-belgium-1 jobmanager.sh[5416]: 2018-08-30 14:53:12,549
> INFO org.apache.flink.runtime.resourcemanager.StandaloneResourceManager -
> Replacing old registration of TaskExecutor 94905ed07a84801aae84b8829c9127a9.
> Aug 30 14:53:12 flink-belgium-1 jobmanager.sh[5416]: 2018-08-30 14:53:12,549
> INFO org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager -
> Unregister TaskManager 5c705cabbbce9b18f1ce258d541236f3 from the SlotManager.
> Aug 30 14:53:12 flink-belgium-1 jobmanager.sh[5416]: 2018-08-30 14:53:12,549
> INFO org.apache.flink.runtime.resourcemanager.StandaloneResourceManager -
> The target with resource ID 94905ed07a84801aae84b8829c9127a9 is already been
> monitored.
> Aug 30 14:53:12 flink-belgium-1 jobmanager.sh[5416]: 2018-08-30 14:53:12,693
> INFO org.apache.flink.runtime.resourcemanager.StandaloneResourceManager -
> Replacing old registration of TaskExecutor 1fb9586b081ae447a1b6980d1ab3db21.
> Aug 30 14:53:12 flink-belgium-1 jobmanager.sh[5416]: 2018-08-30 14:53:12,694
> INFO org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager -
> Unregister TaskManager 5b6ce31be7cc46491c162daad61b24c2 from the SlotManager.
> Aug 30 14:53:12 flink-belgium-1 jobmanager.sh[5416]: 2018-08-30 14:53:12,694
> INFO org.apache.flink.runtime.resourcemanager.StandaloneResourceManager -
> The target with resource ID 1fb9586b081ae447a1b6980d1ab3db21 is already been
> monitored.
> Aug 30 14:53:12 flink-belgium-1 jobmanager.sh[5416]: 2018-08-30 14:53:12,967
> INFO org.apache.flink.runtime.resourcemanager.StandaloneResourceManager -
> Replacing old registration of TaskExecutor 94905ed07a84801aae84b8829c9127a9.
> Aug 30 14:53:12 flink-belgium-1 jobmanager.sh[5416]: 2018-08-30 14:53:12,968
> INFO org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager -
> Unregister TaskManager dfb624a277f20b02ae20c5eed9b4e1aa from the SlotManager.
> Aug 30 14:53:12 flink-belgium-1 jobmanager.sh[5416]: 2018-08-30 14:53:12,968
> INFO org.apache.flink.runtime.resourcemanager.StandaloneResourceManager -
> The target with resource ID 94905ed07a84801aae84b8829c9127a9 is already been
> monitored.
> Aug 30 14:53:13 flink-belgium-1 jobmanager.sh[5416]: 2018-08-30 14:53:13,114
> INFO org.apache.flink.runtime.resourcemanager.StandaloneResourceManager -
> Replacing old registration of TaskExecutor 1fb9586b081ae447a1b6980d1ab3db21.
> Aug 30 14:53:13 flink-belgium-1 jobmanager.sh[5416]: 2018-08-30 14:53:13,114
> INFO org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager -
> Unregister TaskManager f3f603bfaa7100e9f9fcd8ec84959430 from the SlotManager.
> Aug 30 14:53:13 flink-belgium-1 jobmanager.sh[5416]: 2018-08-30 14:53:13,114
> INFO org.apache.flink.runtime.resourcemanager.StandaloneResourceManager -
> The target with resource ID 1fb9586b081ae447a1b6980d1ab3db21 is already been
> monitored.
> Aug 30 14:53:13 flink-belgium-1 jobmanager.sh[5416]: 2018-08-30 14:53:13,210
> INFO org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager -
> Registering TaskManager 94905ed07a84801aae84b8829c9127a9 under
> 4307116dff858852034ef1332eab8261 at the SlotManager.
> Aug 30 14:53:13 flink-belgium-1 jobmanager.sh[5416]: 2018-08-30 14:53:13,354
> INFO org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager -
> Registering TaskManager 1fb9586b081ae447a1b6980d1ab3db21 under
> 08e12e11a71a7ab797b3a5a9ae281715 at the SlotManager.
> Aug 30 14:53:19 flink-belgium-1 jobmanager.sh[5416]: 2018-08-30 14:53:19,241
> INFO org.apache.flink.runtime.resourcemanager.StandaloneResourceManager -
> Replacing old registration of TaskExecutor 6bd63995405f236408d095e164f09317.
> Aug 30 14:53:19 flink-belgium-1 jobmanager.sh[5416]: 2018-08-30 14:53:19,242
> INFO org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager -
> Unregister TaskManager 884ce66a1dcc8fc8bc719b1dd7571f1f from the SlotManager.
> Aug 30 14:53:19 flink-belgium-1 jobmanager.sh[5416]: 2018-08-30 14:53:19,242
> INFO org.apache.flink.runtime.resourcemanager.StandaloneResourceManager -
> The target with resource ID 6bd63995405f236408d095e164f09317 is already been
> monitored.
> Aug 30 14:53:19 flink-belgium-1 jobmanager.sh[5416]: 2018-08-30 14:53:19,318
> INFO org.apache.flink.runtime.resourcemanager.StandaloneResourceManager -
> Replacing old registration of TaskExecutor e1069a45feac2cd3c4f5144a062ede0e.
> Aug 30 14:53:19 flink-belgium-1 jobmanager.sh[5416]: 2018-08-30 14:53:19,318
> INFO org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager -
> Unregister TaskManager 5e753aae88167fc5a48b99fc8a9025bf from the SlotManager.
> Aug 30 14:53:19 flink-belgium-1 jobmanager.sh[5416]: 2018-08-30 14:53:19,318
> INFO org.apache.flink.runtime.resourcemanager.StandaloneResourceManager -
> The target with resource ID e1069a45feac2cd3c4f5144a062ede0e is already been
> monitored.
> Aug 30 14:53:19 flink-belgium-1 jobmanager.sh[5416]: 2018-08-30 14:53:19,460
> INFO org.apache.flink.runtime.resourcemanager.StandaloneResourceManager -
> Replacing old registration of TaskExecutor 6bd63995405f236408d095e164f09317.
> Aug 30 14:53:19 flink-belgium-1 jobmanager.sh[5416]: 2018-08-30 14:53:19,460
> INFO org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager -
> Unregister TaskManager 1eac33f7136c771097b7bc5e027ca45b from the SlotManager.
> Aug 30 14:53:19 flink-belgium-1 jobmanager.sh[5416]: 2018-08-30 14:53:19,460
> INFO org.apache.flink.runtime.resourcemanager.StandaloneResourceManager -
> The target with resource ID 6bd63995405f236408d095e164f09317 is already been
> monitored.
> Aug 30 14:53:19 flink-belgium-1 jobmanager.sh[5416]: 2018-08-30 14:53:19,535
> INFO org.apache.flink.runtime.resourcemanager.StandaloneResourceManager -
> Replacing old registration of TaskExecutor e1069a45feac2cd3c4f5144a062ede0e.
> Aug 30 14:53:19 flink-belgium-1 jobmanager.sh[5416]: 2018-08-30 14:53:19,536
> INFO org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager -
> Unregister TaskManager c718ebda4262aefdc78cf844f164f96e from the SlotManager.
> Aug 30 14:53:19 flink-belgium-1 jobmanager.sh[5416]: 2018-08-30 14:53:19,536
> INFO org.apache.flink.runtime.resourcemanager.StandaloneResourceManager -
> The target with resource ID e1069a45feac2cd3c4f5144a062ede0e is already been
> monitored.
> Aug 30 14:53:19 flink-belgium-1 jobmanager.sh[5416]: 2018-08-30 14:53:19,880
> INFO org.apache.flink.runtime.resourcemanager.StandaloneResourceManager -
> Replacing old registration of TaskExecutor 6bd63995405f236408d095e164f09317.
> Aug 30 14:53:19 flink-belgium-1 jobmanager.sh[5416]: 2018-08-30 14:53:19,880
> INFO org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager -
> Unregister TaskManager a14bea581e643fedbd888a24e0e15ac0 from the SlotManager.
> Aug 30 14:53:19 flink-belgium-1 jobmanager.sh[5416]: 2018-08-30 14:53:19,880
> INFO org.apache.flink.runtime.resourcemanager.StandaloneResourceManager -
> The target with resource ID 6bd63995405f236408d095e164f09317 is already been
> monitored.
> Aug 30 14:53:19 flink-belgium-1 jobmanager.sh[5416]: 2018-08-30 14:53:19,957
> INFO org.apache.flink.runtime.resourcemanager.StandaloneResourceManager -
> Replacing old registration of TaskExecutor e1069a45feac2cd3c4f5144a062ede0e.
> Aug 30 14:53:19 flink-belgium-1 jobmanager.sh[5416]: 2018-08-30 14:53:19,957
> INFO org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager -
> Unregister TaskManager 5a20fdf8c43c809a56a103a5036b36d7 from the SlotManager.
> Aug 30 14:53:19 flink-belgium-1 jobmanager.sh[5416]: 2018-08-30 14:53:19,957
> INFO org.apache.flink.runtime.resourcemanager.StandaloneResourceManager -
> The target with resource ID e1069a45feac2cd3c4f5144a062ede0e is already been
> monitored.
> Aug 30 14:53:20 flink-belgium-1 jobmanager.sh[5416]: 2018-08-30 14:53:20,700
> INFO org.apache.flink.runtime.resourcemanager.StandaloneResourceManager -
> Replacing old registration of TaskExecutor 6bd63995405f236408d095e164f09317.
> Aug 30 14:53:20 flink-belgium-1 jobmanager.sh[5416]: 2018-08-30 14:53:20,700
> INFO org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager -
> Unregister TaskManager 4923f236220686b3b03502a5be1eb9ad from the SlotManager.
> Aug 30 14:53:20 flink-belgium-1 jobmanager.sh[5416]: 2018-08-30 14:53:20,700
> INFO org.apache.flink.runtime.resourcemanager.StandaloneResourceManager -
> The target with resource ID 6bd63995405f236408d095e164f09317 is already been
> monitored.
> Aug 30 14:53:20 flink-belgium-1 jobmanager.sh[5416]: 2018-08-30 14:53:20,775
> INFO org.apache.flink.runtime.resourcemanager.StandaloneResourceManager -
> Replacing old registration of TaskExecutor e1069a45feac2cd3c4f5144a062ede0e.
> Aug 30 14:53:20 flink-belgium-1 jobmanager.sh[5416]: 2018-08-30 14:53:20,776
> INFO org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager -
> Unregister TaskManager 631fc8175a3b9cabca7fd48519c368a2 from the SlotManager.
> Aug 30 14:53:20 flink-belgium-1 jobmanager.sh[5416]: 2018-08-30 14:53:20,776
> INFO org.apache.flink.runtime.resourcemanager.StandaloneResourceManager -
> The target with resource ID e1069a45feac2cd3c4f5144a062ede0e is already been
> monitored.
> Aug 30 14:53:20 flink-belgium-1 jobmanager.sh[5416]: 2018-08-30 14:53:20,991
> INFO org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager -
> Registering TaskManager 6bd63995405f236408d095e164f09317 under
> 73d6551c81d2c0cd469e899cb02e09b3 at the SlotManager.
> Aug 30 14:53:21 flink-belgium-1 jobmanager.sh[5416]: 2018-08-30 14:53:21,068
> INFO org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager -
> Registering TaskManager e1069a45feac2cd3c4f5144a062ede0e under
> 62586c6113f081939dd43d0ead7d49ec at the SlotManager.
> Aug 30 14:53:21 flink-belgium-1 jobmanager.sh[5416]: 2018-08-30 14:53:21,960
> INFO org.apache.flink.runtime.resourcemanager.StandaloneResourceManager -
> Replacing old registration of TaskExecutor 310b82f63d95ab2733b87ad1e88bbd30.
> Aug 30 14:53:21 flink-belgium-1 jobmanager.sh[5416]: 2018-08-30 14:53:21,961
> INFO org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager -
> Unregister TaskManager 4054f5fbcdc7cb38956494c3eed5d71b from the SlotManager.
> Aug 30 14:53:21 flink-belgium-1 jobmanager.sh[5416]: 2018-08-30 14:53:21,961
> INFO org.apache.flink.runtime.resourcemanager.StandaloneResourceManager -
> The target with resource ID 310b82f63d95ab2733b87ad1e88bbd30 is already been
> monitored.
> Aug 30 14:53:22 flink-belgium-1 jobmanager.sh[5416]: 2018-08-30 14:53:22,177
> INFO org.apache.flink.runtime.resourcemanager.StandaloneResourceManager -
> Replacing old registration of TaskExecutor 310b82f63d95ab2733b87ad1e88bbd30.
> Aug 30 14:53:22 flink-belgium-1 jobmanager.sh[5416]: 2018-08-30 14:53:22,177
> INFO org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager -
> Unregister TaskManager 293798a8d6417a8ce247bdb2f159e0c6 from the SlotManager.
> Aug 30 14:53:22 flink-belgium-1 jobmanager.sh[5416]: 2018-08-30 14:53:22,177
> INFO org.apache.flink.runtime.resourcemanager.StandaloneResourceManager -
> The target with resource ID 310b82f63d95ab2733b87ad1e88bbd30 is already been
> monitored.
> Aug 30 14:53:22 flink-belgium-1 jobmanager.sh[5416]: 2018-08-30 14:53:22,279
> INFO org.apache.flink.runtime.resourcemanager.StandaloneResourceManager -
> Replacing old registration of TaskExecutor 75604e05f624849effd13b197851428d.
> Aug 30 14:53:22 flink-belgium-1 jobmanager.sh[5416]: 2018-08-30 14:53:22,280
> INFO org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager -
> Unregister TaskManager d855d9a95809c906ca6b685f1f63345e from the SlotManager.
> Aug 30 14:53:22 flink-belgium-1 jobmanager.sh[5416]: 2018-08-30 14:53:22,280
> INFO org.apache.flink.runtime.resourcemanager.StandaloneResourceManager -
> The target with resource ID 75604e05f624849effd13b197851428d is already been
> monitored.
> Aug 30 14:53:22 flink-belgium-1 jobmanager.sh[5416]: 2018-08-30 14:53:22,496
> INFO org.apache.flink.runtime.resourcemanager.StandaloneResourceManager -
> Replacing old registration of TaskExecutor 75604e05f624849effd13b197851428d.
> Aug 30 14:53:22 flink-belgium-1 jobmanager.sh[5416]: 2018-08-30 14:53:22,497
> INFO org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager -
> Unregister TaskManager 1bd7ff5b2cf551dde6cde3b14458ccab from the SlotManager.
> Aug 30 14:53:22 flink-belgium-1 jobmanager.sh[5416]: 2018-08-30 14:53:22,497
> INFO org.apache.flink.runtime.resourcemanager.StandaloneResourceManager -
> The target with resource ID 75604e05f624849effd13b197851428d is already been
> monitored.
> Aug 30 14:53:22 flink-belgium-1 jobmanager.sh[5416]: 2018-08-30 14:53:22,599
> INFO org.apache.flink.runtime.resourcemanager.StandaloneResourceManager -
> Replacing old registration of TaskExecutor 310b82f63d95ab2733b87ad1e88bbd30.
> Aug 30 14:53:22 flink-belgium-1 jobmanager.sh[5416]: 2018-08-30 14:53:22,600
> INFO org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager -
> Unregister TaskManager d7f3d6e596ffe61fba6889a286c668b3 from the SlotManager.
> Aug 30 14:53:22 flink-belgium-1 jobmanager.sh[5416]: 2018-08-30 14:53:22,600
> INFO org.apache.flink.runtime.resourcemanager.StandaloneResourceManager -
> The target with resource ID 310b82f63d95ab2733b87ad1e88bbd30 is already been
> monitored.
> Aug 30 14:53:22 flink-belgium-1 jobmanager.sh[5416]: 2018-08-30 14:53:22,828
> INFO org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager -
> Registering TaskManager 310b82f63d95ab2733b87ad1e88bbd30 under
> 0a3ac92e2ff9f075f38c5d838bfdc664 at the SlotManager.
> Aug 30 14:53:22 flink-belgium-1 jobmanager.sh[5416]: 2018-08-30 14:53:22,916
> INFO org.apache.flink.runtime.resourcemanager.StandaloneResourceManager -
> Replacing old registration of TaskExecutor 75604e05f624849effd13b197851428d.
> Aug 30 14:53:22 flink-belgium-1 jobmanager.sh[5416]: 2018-08-30 14:53:22,917
> INFO org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager -
> Unregister TaskManager 43b76db2726fccad139b9b570e5a0d2e from the SlotManager.
> Aug 30 14:53:22 flink-belgium-1 jobmanager.sh[5416]: 2018-08-30 14:53:22,917
> INFO org.apache.flink.runtime.resourcemanager.StandaloneResourceManager -
> The target with resource ID 75604e05f624849effd13b197851428d is already been
> monitored.
> Aug 30 14:53:23 flink-belgium-1 jobmanager.sh[5416]: 2018-08-30 14:53:23,141
> INFO org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager -
> Registering TaskManager 75604e05f624849effd13b197851428d under
> 16f5d0cae8bbc6ea6f8cd90b53607422 at the SlotManager.
> {code}
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
