Fix a bug that returns nothing

loustler · Sep 27, 2024 · 5394810 · 5394810
1 parent 156b087
commit 5394810
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/...-engine-server/src/main/java/org/apache/seatunnel/engine/server/SeaTunnelNodeContext.java b/...-engine-server/src/main/java/org/apache/seatunnel/engine/server/SeaTunnelNodeContext.java
@@ -54,14 +54,14 @@ public Joiner createJoiner(Node node) {
         join.verify();
 
         if (node.shouldUseMulticastJoiner(join) && node.multicastService != null) {
-            super.createJoiner(node);
+            return super.createJoiner(node);
         } else if (join.getTcpIpConfig().isEnabled()) {
             log.info("Using LiteNodeDropOutTcpIpJoiner TCP/IP discovery");
             return new LiteNodeDropOutTcpIpJoiner(node);
         } else if (node.getProperties().getBoolean(DISCOVERY_SPI_ENABLED)
                 || isAnyAliasedConfigEnabled(join)
                 || join.isAutoDetectionEnabled()) {
-            super.createJoiner(node);
+            return super.createJoiner(node);
         }
         return null;
     }