[
https://issues.apache.org/jira/browse/FLINK-10260?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16623206#comment-16623206
]
ASF GitHub Bot commented on FLINK-10260:
----------------------------------------
asfgit closed pull request #6720: [FLINK-10260] Change log level to debug in
ResourceManager in case of TaskExecutor reconnect
URL: https://github.com/apache/flink/pull/6720
This is a PR merged from a forked repository.
As GitHub hides the original diff on merge, it is displayed below for
the sake of provenance:
As this is a foreign pull request (from a fork), the diff is supplied
below (as it won't show otherwise due to GitHub magic):
diff --git
a/flink-runtime/src/main/java/org/apache/flink/runtime/heartbeat/HeartbeatManagerImpl.java
b/flink-runtime/src/main/java/org/apache/flink/runtime/heartbeat/HeartbeatManagerImpl.java
index 242fbaa086a..15a3757ab35 100644
---
a/flink-runtime/src/main/java/org/apache/flink/runtime/heartbeat/HeartbeatManagerImpl.java
+++
b/flink-runtime/src/main/java/org/apache/flink/runtime/heartbeat/HeartbeatManagerImpl.java
@@ -118,7 +118,7 @@ Executor getExecutor() {
public void monitorTarget(ResourceID resourceID, HeartbeatTarget<O>
heartbeatTarget) {
if (!stopped) {
if (heartbeatTargets.containsKey(resourceID)) {
- log.info("The target with resource ID {} is
already been monitored.", resourceID);
+ log.debug("The target with resource ID {} is
already been monitored.", resourceID);
} else {
HeartbeatManagerImpl.HeartbeatMonitor<O>
heartbeatMonitor = new HeartbeatManagerImpl.HeartbeatMonitor<>(
resourceID,
diff --git
a/flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/ResourceManager.java
b/flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/ResourceManager.java
index 39844839453..ac1181b1d1d 100644
---
a/flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/ResourceManager.java
+++
b/flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/ResourceManager.java
@@ -694,7 +694,7 @@ private RegistrationResponse registerTaskExecutorInternal(
WorkerRegistration<WorkerType> oldRegistration =
taskExecutors.remove(taskExecutorResourceId);
if (oldRegistration != null) {
// TODO :: suggest old taskExecutor to stop itself
- log.info("Replacing old registration of TaskExecutor
{}.", taskExecutorResourceId);
+ log.debug("Replacing old registration of TaskExecutor
{}.", taskExecutorResourceId);
// remove old task manager registration from slot
manager
slotManager.unregisterTaskManager(oldRegistration.getInstanceID());
diff --git
a/flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/slotmanager/SlotManager.java
b/flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/slotmanager/SlotManager.java
index d54d1434bf1..bab56609a1b 100644
---
a/flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/slotmanager/SlotManager.java
+++
b/flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/slotmanager/SlotManager.java
@@ -324,7 +324,7 @@ public boolean unregisterSlotRequest(AllocationID
allocationId) {
public void registerTaskManager(final TaskExecutorConnection
taskExecutorConnection, SlotReport initialSlotReport) {
checkInit();
- LOG.info("Registering TaskManager {} under {} at the
SlotManager.", taskExecutorConnection.getResourceID(),
taskExecutorConnection.getInstanceID());
+ LOG.debug("Registering TaskManager {} under {} at the
SlotManager.", taskExecutorConnection.getResourceID(),
taskExecutorConnection.getInstanceID());
// we identify task managers by their instance id
if
(taskManagerRegistrations.containsKey(taskExecutorConnection.getInstanceID())) {
@@ -366,7 +366,7 @@ public void registerTaskManager(final
TaskExecutorConnection taskExecutorConnect
public boolean unregisterTaskManager(InstanceID instanceId) {
checkInit();
- LOG.info("Unregister TaskManager {} from the SlotManager.",
instanceId);
+ LOG.debug("Unregister TaskManager {} from the SlotManager.",
instanceId);
TaskManagerRegistration taskManagerRegistration =
taskManagerRegistrations.remove(instanceId);
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
> 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)
