(flink) branch master updated: [FLINK-36011][runtime] Improved logging in StateTransitionManager

[mapohl]

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

mapohl 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 f1bff1ef791 [FLINK-36011][runtime] Improved logging in 
StateTransitionManager
f1bff1ef791 is described below

commit f1bff1ef791e7eabd1005f597e8a97328f885808
Author: Zdenek Tison <zti...@confluent.io>
AuthorDate: Tue Oct 29 10:31:44 2024 +0100

    [FLINK-36011][runtime] Improved logging in StateTransitionManager
---
 .../scheduler/adaptive/DefaultStateTransitionManager.java        | 9 ++++++++-
 1 file changed, 8 insertions(+), 1 deletion(-)

diff --git 
a/flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptive/DefaultStateTransitionManager.java
 
b/flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptive/DefaultStateTransitionManager.java
index 4c7be2ed349..890e8c535ed 100644
--- 
a/flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptive/DefaultStateTransitionManager.java
+++ 
b/flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptive/DefaultStateTransitionManager.java
@@ -157,7 +157,7 @@ public class DefaultStateTransitionManager implements 
StateTransitionManager {
         Preconditions.checkState(
                 !(phase instanceof Transitioning),
                 "The state transition operation has already been triggered.");
-        LOG.debug("Transitioning from {} to {}.", phase, newPhase);
+        LOG.info("Transitioning from {} to {}.", phase, newPhase);
         phase = newPhase;
     }
 
@@ -228,6 +228,11 @@ public class DefaultStateTransitionManager implements 
StateTransitionManager {
         void onChange() {}
 
         void onTrigger() {}
+
+        @Override
+        public String toString() {
+            return getClass().getSimpleName();
+        }
     }
 
     /**
@@ -345,6 +350,7 @@ public class DefaultStateTransitionManager implements 
StateTransitionManager {
 
         private void transitionToSubSequentStateForDesiredResources() {
             if (hasDesiredResources()) {
+                LOG.info("Desired resources are met, transitioning to the 
subsequent state.");
                 context().triggerTransitionToSubsequentState();
             } else {
                 LOG.debug(
@@ -373,6 +379,7 @@ public class DefaultStateTransitionManager implements 
StateTransitionManager {
         @Override
         void onTrigger() {
             if (hasSufficientResources()) {
+                LOG.info("Sufficient resources are met, progressing to 
subsequent state.");
                 context().triggerTransitionToSubsequentState();
             } else {
                 LOG.debug("Sufficient resources are not met, progressing to 
idling.");