From 38c398ec3c2c900714a0b57afc8d8c3f9efc0aa6 Mon Sep 17 00:00:00 2001
From: wangbo <506340561@qq.com>
Date: Mon, 9 Sep 2024 14:11:32 +0800
Subject: [PATCH] only publish topic to alive be

---
 .../apache/doris/common/publish/TopicPublisherThread.java    | 5 ++++-
 1 file changed, 4 insertions(+), 1 deletion(-)

diff --git a/fe/fe-core/src/main/java/org/apache/doris/common/publish/TopicPublisherThread.java b/fe/fe-core/src/main/java/org/apache/doris/common/publish/TopicPublisherThread.java
index 74cefeca4d907e..797b0893936513 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/common/publish/TopicPublisherThread.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/common/publish/TopicPublisherThread.java
@@ -85,10 +85,13 @@ protected void runAfterCatalogReady() {
         }
         AckResponseHandler handler = new AckResponseHandler(nodesToPublish);
         for (Backend be : nodesToPublish) {
-            executor.submit(new TopicPublishWorker(request, be, handler));
+            if (be.isAlive()) {
+                executor.submit(new TopicPublishWorker(request, be, handler));
+            }
         }
         try {
             int timeoutMs = Config.publish_topic_info_interval_ms / 3 * 2;
+            timeoutMs = timeoutMs <= 0 ? 3000 : timeoutMs;
             if (!handler.awaitAllInMs(timeoutMs)) {
                 Backend[] backends = handler.pendingNodes();
                 if (backends.length > 0) {