From issues-return-189559-archive-asf-public=cust-asf.ponee.io@flink.apache.org Thu Sep 20 11:58:08 2018 Return-Path: X-Original-To: archive-asf-public@cust-asf.ponee.io Delivered-To: archive-asf-public@cust-asf.ponee.io Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by mx-eu-01.ponee.io (Postfix) with SMTP id 500C1180671 for ; Thu, 20 Sep 2018 11:58:07 +0200 (CEST) Received: (qmail 9215 invoked by uid 500); 20 Sep 2018 09:58:06 -0000 Mailing-List: contact issues-help@flink.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@flink.apache.org Delivered-To: mailing list issues@flink.apache.org Received: (qmail 9206 invoked by uid 99); 20 Sep 2018 09:58:06 -0000 Received: from pnap-us-west-generic-nat.apache.org (HELO spamd4-us-west.apache.org) (209.188.14.142) by apache.org (qpsmtpd/0.29) with ESMTP; Thu, 20 Sep 2018 09:58:06 +0000 Received: from localhost (localhost [127.0.0.1]) by spamd4-us-west.apache.org (ASF Mail Server at spamd4-us-west.apache.org) with ESMTP id F3731C03DE for ; Thu, 20 Sep 2018 09:58:05 +0000 (UTC) X-Virus-Scanned: Debian amavisd-new at spamd4-us-west.apache.org X-Spam-Flag: NO X-Spam-Score: -109.25 X-Spam-Level: X-Spam-Status: No, score=-109.25 tagged_above=-999 required=6.31 tests=[ENV_AND_HDR_SPF_MATCH=-0.5, KAM_ASCII_DIVIDERS=0.8, KAM_LOTSOFHASH=0.25, RCVD_IN_DNSWL_MED=-2.3, SPF_PASS=-0.001, USER_IN_DEF_SPF_WL=-7.5, USER_IN_WHITELIST=-100, WEIRD_PORT=0.001] autolearn=disabled Received: from mx1-lw-us.apache.org ([10.40.0.8]) by localhost (spamd4-us-west.apache.org [10.40.0.11]) (amavisd-new, port 10024) with ESMTP id 1dy2wyW_ILOv for ; Thu, 20 Sep 2018 09:58:01 +0000 (UTC) Received: from mailrelay1-us-west.apache.org (mailrelay1-us-west.apache.org [209.188.14.139]) by mx1-lw-us.apache.org (ASF Mail Server at mx1-lw-us.apache.org) with ESMTP id 5F48F5F42F for ; Thu, 20 Sep 2018 09:58:01 +0000 (UTC) Received: from jira-lw-us.apache.org (unknown [207.244.88.139]) by mailrelay1-us-west.apache.org (ASF Mail Server at mailrelay1-us-west.apache.org) with ESMTP id E6F80E1013 for ; Thu, 20 Sep 2018 09:58:00 +0000 (UTC) Received: from jira-lw-us.apache.org (localhost [127.0.0.1]) by jira-lw-us.apache.org (ASF Mail Server at jira-lw-us.apache.org) with ESMTP id 4F21D23FA3 for ; Thu, 20 Sep 2018 09:58:00 +0000 (UTC) Date: Thu, 20 Sep 2018 09:58:00 +0000 (UTC) From: "Andrey Zagrebin (JIRA)" To: issues@flink.apache.org Message-ID: In-Reply-To: References: Subject: [jira] [Assigned] (FLINK-10260) Confusing log during TaskManager registration MIME-Version: 1.0 Content-Type: text/plain; charset=utf-8 Content-Transfer-Encoding: 7bit X-JIRA-FingerPrint: 30527f35849b9dde25b450d4833f0394 [ https://issues.apache.org/jira/browse/FLINK-10260?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrey Zagrebin reassigned FLINK-10260: --------------------------------------- Assignee: Andrey Zagrebin > 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)