Skip to content

Commit 352e9ff

Browse files
author
chengyitian
committed
AJ-860: fix issue about '<DataNodeNotReady>' reconnect;
1 parent 26202c6 commit 352e9ff

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

src/com/xxdb/DBConnection.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1396,7 +1396,7 @@ public ExceptionType parseException(String msg, Node node) {
13961396
log.info("New leader is " + node.hostName + ":" + node.port);
13971397
return ExceptionType.ET_NEWLEADER;
13981398
}
1399-
}else if ((index = msg.indexOf("<DataNodeNotAvail>")) != -1){
1399+
}else if (msg.contains("<DataNodeNotAvail>") || msg.contains("<DataNodeNotReady>")){
14001400
node.hostName = "";
14011401
node.port = 0;
14021402
return ExceptionType.ET_NODENOTAVAIL;

0 commit comments

Comments
 (0)