From dab9326f1fe62d5bc3fe10efbe50afe0841edb57 Mon Sep 17 00:00:00 2001 From: wenyh <44251917+wenyh1@users.noreply.github.com> Date: Tue, 19 Sep 2023 14:37:06 +0800 Subject: [PATCH] [inner-2356] adjust tips --- .../com/actiontech/dble/backend/datasource/PhysicalDbGroup.java | 2 +- src/main/java/com/actiontech/dble/singleton/ThreadManager.java | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/src/main/java/com/actiontech/dble/backend/datasource/PhysicalDbGroup.java b/src/main/java/com/actiontech/dble/backend/datasource/PhysicalDbGroup.java index ea0156954d..24d0cd5510 100644 --- a/src/main/java/com/actiontech/dble/backend/datasource/PhysicalDbGroup.java +++ b/src/main/java/com/actiontech/dble/backend/datasource/PhysicalDbGroup.java @@ -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(); diff --git a/src/main/java/com/actiontech/dble/singleton/ThreadManager.java b/src/main/java/com/actiontech/dble/singleton/ThreadManager.java index 85af0d958f..2b47c6018e 100644 --- a/src/main/java/com/actiontech/dble/singleton/ThreadManager.java +++ b/src/main/java/com/actiontech/dble/singleton/ThreadManager.java @@ -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");