[FLINK-16619][coordination] Log reception of slot reports only once

apache · Aug 3, 2020 · 7d39a2c · 7d39a2c
1 parent 1ae668a
commit 7d39a2c
Showing 1 changed file with 1 addition and 2 deletions.
diff --git a/...e/src/main/java/org/apache/flink/runtime/resourcemanager/slotmanager/SlotManagerImpl.java b/...e/src/main/java/org/apache/flink/runtime/resourcemanager/slotmanager/SlotManagerImpl.java
@@ -508,11 +508,10 @@ public boolean unregisterTaskManager(InstanceID instanceId, Exception cause) {
 	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());