From 79e24c53f53864db4909da8d2da1af0445e79c73 Mon Sep 17 00:00:00 2001
From: emptyOVO <gaoyifei040229@163.com>
Date: Fri, 20 Sep 2024 21:05:25 +0800
Subject: [PATCH] feat: optimize printCurrentState method logic

---
 .../org/apache/inlong/agent/plugin/sources/RedisSource.java  | 5 +++--
 1 file changed, 3 insertions(+), 2 deletions(-)

diff --git a/inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/sources/RedisSource.java b/inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/sources/RedisSource.java
index 172f523743..aada1bf504 100644
--- a/inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/sources/RedisSource.java
+++ b/inlong-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