We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 7ae5f55 commit 035f080Copy full SHA for 035f080
src/main/java/com/actiontech/dble/server/OfflineStatusListener.java
@@ -91,7 +91,7 @@ private void releaseForBinlog(String crashNode) {
91
CuratorFramework zkConn = ZKUtils.getConnection();
92
try {
93
byte[] binlogStatusData = zkConn.getData().forPath(binlogStatusPath);
94
- if (binlogStatusData == null) {
+ if (binlogStatusData == null || binlogStatusData.length == 0) {
95
return;
96
}
97
String data = new String(binlogStatusData, StandardCharsets.UTF_8);
0 commit comments