[flink] branch master updated: [FLINK-16619][coordination] Log reception of slot reports only once

[chesnay]

This is an automated email from the ASF dual-hosted git repository.

chesnay pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git


The following commit(s) were added to refs/heads/master by this push:
     new 7d39a2c  [FLINK-16619][coordination] Log reception of slot reports 
only once
7d39a2c is described below

commit 7d39a2c7cd23c990800671787916751e04720252
Author: Chesnay Schepler <ches...@apache.org>
AuthorDate: Mon Aug 3 10:49:46 2020 +0200

    [FLINK-16619][coordination] Log reception of slot reports only once
---
 .../flink/runtime/resourcemanager/slotmanager/SlotManagerImpl.java     | 3 +--
 1 file changed, 1 insertion(+), 2 deletions(-)

diff --git 
a/flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/slotmanager/SlotManagerImpl.java
 
b/flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/slotmanager/SlotManagerImpl.java
index b4937c2..48decfe 100755
--- 
a/flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/slotmanager/SlotManagerImpl.java
+++ 
b/flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/slotmanager/SlotManagerImpl.java
@@ -508,11 +508,10 @@ public class SlotManagerImpl implements SlotManager {
        public boolean reportSlotStatus(InstanceID instanceId, SlotReport 
slotReport) {
                checkInit();
 
-               LOG.debug("Received slot report from instance {}: {}.", 
instanceId, slotReport);
-
                TaskManagerRegistration taskManagerRegistration = 
taskManagerRegistrations.get(instanceId);
 
                if (null != taskManagerRegistration) {
+                       LOG.debug("Received slot report from instance {}: {}.", 
instanceId, slotReport);
 
                        for (SlotStatus slotStatus : slotReport) {
                                updateSlot(slotStatus.getSlotID(), 
slotStatus.getAllocationID(), slotStatus.getJobID());