(seatunnel) branch dev updated: [Fix] [Zeta] CoordinatorService initialization retry on failure (#10580)

[shenghang]

This is an automated email from the ASF dual-hosted git repository.

shenghang pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/seatunnel.git


The following commit(s) were added to refs/heads/dev by this push:
     new d635407ac3 [Fix] [Zeta] CoordinatorService initialization retry on 
failure (#10580)
d635407ac3 is described below

commit d635407ac3dc509b5b25f2c3e3738df2faa27f94
Author: corgy-w <73771213+corg...@users.noreply.github.com>
AuthorDate: Mon Mar 30 20:18:10 2026 +0800

    [Fix] [Zeta] CoordinatorService initialization retry on failure (#10580)
---
 .../org/apache/seatunnel/engine/server/CoordinatorService.java    | 8 ++++++--
 1 file changed, 6 insertions(+), 2 deletions(-)

diff --git 
a/seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/CoordinatorService.java
 
b/seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/CoordinatorService.java
index f4273ed497..8758c96e7d 100644
--- 
a/seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/CoordinatorService.java
+++ 
b/seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/CoordinatorService.java
@@ -770,8 +770,12 @@ public class CoordinatorService {
             }
         } catch (Exception e) {
             isActive = false;
-            logger.severe(ExceptionUtils.getMessage(e));
-            throw new SeaTunnelEngineException("check new active master error, 
stop loop", e);
+            logger.severe("check new active master error, will retry later.", 
e);
+            try {
+                clearCoordinatorService();
+            } catch (Exception ex) {
+                logger.warning("clear coordinator service failed.", ex);
+            }
         }
     }