diff --git a/src/main/java/com/actiontech/dble/server/OfflineStatusListener.java b/src/main/java/com/actiontech/dble/server/OfflineStatusListener.java index 55059cb64..0c5f8c3b6 100644 --- a/src/main/java/com/actiontech/dble/server/OfflineStatusListener.java +++ b/src/main/java/com/actiontech/dble/server/OfflineStatusListener.java @@ -91,7 +91,7 @@ public class OfflineStatusListener implements PathChildrenCacheListener { CuratorFramework zkConn = ZKUtils.getConnection(); try { byte[] binlogStatusData = zkConn.getData().forPath(binlogStatusPath); - if (binlogStatusData == null) { + if (binlogStatusData == null || binlogStatusData.length == 0) { return; } String data = new String(binlogStatusData, StandardCharsets.UTF_8);