feat: optimize printCurrentState method logic

apache · Sep 20, 2024 · 79e24c5 · 79e24c5
1 parent 0d3d4c6
commit 79e24c5
Showing 1 changed file with 3 additions and 2 deletions.
diff --git a/...agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/sources/RedisSource.java b/...agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/sources/RedisSource.java
@@ -294,9 +294,10 @@ protected void printCurrentState() {
             LOGGER.info("redis subscribe synchronization is {} on source {}",
                     redisReplicator != null && !executor.isShutdown() ? "running" : "stop",
                     hostName + ":" + port);
+        } else {
+            LOGGER.info("redis command synchronization is {} on source {}", !executor.isShutdown() ? "running" : "stop",
+                    hostName + ":" + port);
         }
-        LOGGER.info("redis command synchronization is {} on source {}", !executor.isShutdown() ? "running" : "stop",
-                hostName + ":" + port);
     }
 
     @Override