[flink] branch release-1.13 updated: [FLINK-22351][coordination] Promote resource declaration log to INFO in FineGrainedSlotManager

[xtsong]

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

xtsong pushed a commit to branch release-1.13
in repository https://gitbox.apache.org/repos/asf/flink.git


The following commit(s) were added to refs/heads/release-1.13 by this push:
     new 123c1c4  [FLINK-22351][coordination] Promote resource declaration log 
to INFO in FineGrainedSlotManager
123c1c4 is described below

commit 123c1c4d1ea97c9614f838523ad7757e00dff359
Author: Yangze Guo <karma...@gmail.com>
AuthorDate: Mon Apr 19 17:39:23 2021 +0800

    [FLINK-22351][coordination] Promote resource declaration log to INFO in 
FineGrainedSlotManager
    
    This closes # 15669
---
 .../resourcemanager/slotmanager/FineGrainedSlotManager.java  | 12 ++++++++----
 1 file changed, 8 insertions(+), 4 deletions(-)

diff --git 
a/flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/slotmanager/FineGrainedSlotManager.java
 
b/flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/slotmanager/FineGrainedSlotManager.java
index a775c93..f632357 100644
--- 
a/flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/slotmanager/FineGrainedSlotManager.java
+++ 
b/flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/slotmanager/FineGrainedSlotManager.java
@@ -265,10 +265,14 @@ public class FineGrainedSlotManager implements 
SlotManager {
     @Override
     public void processResourceRequirements(ResourceRequirements 
resourceRequirements) {
         checkInit();
-        LOG.debug(
-                "Received resource requirements from job {}: {}",
-                resourceRequirements.getJobId(),
-                resourceRequirements.getResourceRequirements());
+        if (resourceRequirements.getResourceRequirements().isEmpty()) {
+            LOG.info("Clearing resource requirements of job {}", 
resourceRequirements.getJobId());
+        } else {
+            LOG.info(
+                    "Received resource requirements from job {}: {}",
+                    resourceRequirements.getJobId(),
+                    resourceRequirements.getResourceRequirements());
+        }
 
         if (resourceRequirements.getResourceRequirements().isEmpty()) {
             jobMasterTargetAddresses.remove(resourceRequirements.getJobId());