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