Skip to content

Commit

Permalink
[inner-2356] adjust tips
Browse files Browse the repository at this point in the history
  • Loading branch information
wenyh1 committed Sep 19, 2023
1 parent f6c328d commit dab9326
Show file tree
Hide file tree
Showing 2 changed files with 2 additions and 2 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -330,7 +330,7 @@ public void startHeartbeat() {

public void startDelayDetection() {
for (PhysicalDbInstance dbInstance : allSourceMap.values()) {
if (dbInstance.delayDetection.isStop()) {
if (dbInstance.delayDetection != null && dbInstance.delayDetection.isStop()) {
dbInstance.delayDetection = new DelayDetection(dbInstance);
}
dbInstance.startDelayDetection();
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -115,7 +115,7 @@ public static void recoverSingleThread(String threadName) throws Exception {
}
break;
default:
throw new Exception("The recover operation of threadPool[" + threadName + "] is not supported");
throw new Exception("The recover operation of thread[" + threadName + "] is not supported");
}
} else {
throw new Exception("The recover operation of thread[" + threadName + "] is not supported");
Expand Down

0 comments on commit dab9326

Please sign in to comment.