You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "Andrey Zagrebin (JIRA)" <ji...@apache.org> on 2018/09/20 10:09:00 UTC
[jira] [Commented] (FLINK-10260) Confusing log during TaskManager
registration
[ https://issues.apache.org/jira/browse/FLINK-10260?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16621781#comment-16621781 ]
Andrey Zagrebin commented on FLINK-10260:
-----------------------------------------
It seems that the task executor tries to register with the job master several times and probably does not get a response on time but eventually it happens. It can be a normal scenario if there is some network delay and timeout is too short. In this case, we can just change the log level to debug.
Some messages also seem to miss in the log, e.g. from resource manager, like this:
<Info Registering TaskManager with ResourceID ...>
although, others are there, logged with the same level on the same thread.
[~StephanEwen], could it be that something is filtered out from the log? is it possible to get the most full log from jobmanager.sh and maybe some task managers to get more inside?
> 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
> 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)