[flink] 02/02: [FLINK-23889][runtime] Cleanup unnecessary logging from FineGrainedSlotManager

[xtsong]

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

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

commit f69cc3deb818c949ee7f914ad067884dae346ccb
Author: Yangze Guo <karma...@gmail.com>
AuthorDate: Mon Aug 23 10:56:48 2021 +0800

    [FLINK-23889][runtime] Cleanup unnecessary logging from 
FineGrainedSlotManager
    
    This closes #16934
---
 .../resourcemanager/slotmanager/FineGrainedSlotManager.java       | 8 +-------
 1 file changed, 1 insertion(+), 7 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 e93a699..505c218 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
@@ -485,7 +485,6 @@ public class FineGrainedSlotManager implements SlotManager {
      */
     private void checkResourceRequirementsWithDelay() {
         if (requirementsCheckFuture == null || 
requirementsCheckFuture.isDone()) {
-            LOG.info("Scheduling the resource requirement check.");
             requirementsCheckFuture = new CompletableFuture<>();
             scheduledExecutor.schedule(
                     () ->
@@ -507,13 +506,13 @@ public class FineGrainedSlotManager implements 
SlotManager {
         if (!started) {
             return;
         }
-        LOG.info("Matching resource requirements against available 
resources.");
         Map<JobID, Collection<ResourceRequirement>> missingResources =
                 resourceTracker.getMissingResources();
         if (missingResources.isEmpty()) {
             return;
         }
 
+        LOG.info("Matching resource requirements against available 
resources.");
         missingResources =
                 missingResources.entrySet().stream()
                         .collect(
@@ -525,11 +524,9 @@ public class FineGrainedSlotManager implements SlotManager 
{
                         missingResources, taskManagerTracker);
 
         // Allocate slots according to the result
-        LOG.info("Allocating slots for the resource requirements.");
         allocateSlotsAccordingTo(result.getAllocationsOnRegisteredResources());
 
         // Allocate task managers according to the result
-        LOG.info("Allocating task managers for the resource requirements.");
         final Set<PendingTaskManagerId> failAllocations =
                 
allocateTaskManagersAccordingTo(result.getPendingTaskManagersToAllocate());
 
@@ -708,9 +705,6 @@ public class FineGrainedSlotManager implements SlotManager {
 
     private void releaseIdleTaskExecutor(InstanceID timedOutTaskManagerId) {
         final FlinkException cause = new FlinkException("TaskManager exceeded 
the idle timeout.");
-        LOG.info(
-                "Release TaskManager {} because it exceeded the idle timeout.",
-                timedOutTaskManagerId);
         resourceActions.releaseResource(timedOutTaskManagerId, cause);
     }