[seatunnel] branch dev updated: [Improve] Change hard code config key to reference (#5618)

[wenjun]

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

wenjun 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 2b3fc6c2a8 [Improve] Change hard code config key to reference (#5618)
2b3fc6c2a8 is described below

commit 2b3fc6c2a8b058fd0d51367b6f88bacd3ef9b5f4
Author: Jia Fan <fanjiaemi...@qq.com>
AuthorDate: Mon Oct 16 11:03:32 2023 +0800

    [Improve] Change hard code config key to reference (#5618)
---
 .../java/org/apache/seatunnel/engine/server/SeaTunnelServer.java   | 7 +++++--
 1 file changed, 5 insertions(+), 2 deletions(-)

diff --git 
a/seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/SeaTunnelServer.java
 
b/seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/SeaTunnelServer.java
index 88ee1afc9d..df80cbe637 100644
--- 
a/seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/SeaTunnelServer.java
+++ 
b/seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/SeaTunnelServer.java
@@ -45,6 +45,9 @@ import java.util.concurrent.Executors;
 import java.util.concurrent.ScheduledExecutorService;
 import java.util.concurrent.TimeUnit;
 
+import static 
com.hazelcast.spi.properties.ClusterProperty.INVOCATION_MAX_RETRY_COUNT;
+import static 
com.hazelcast.spi.properties.ClusterProperty.INVOCATION_RETRY_PAUSE;
+
 public class SeaTunnelServer
         implements ManagedService, MembershipAwareService, 
LiveOperationsTracker {
 
@@ -166,7 +169,7 @@ public class SeaTunnelServer
             String hazelcastInvocationMaxRetry =
                     seaTunnelConfig
                             .getHazelcastConfig()
-                            
.getProperty("hazelcast.invocation.max.retry.count");
+                            .getProperty(INVOCATION_MAX_RETRY_COUNT.getName());
             int maxRetry =
                     hazelcastInvocationMaxRetry == null
                             ? 250 * 2
@@ -175,7 +178,7 @@ public class SeaTunnelServer
             String hazelcastRetryPause =
                     seaTunnelConfig
                             .getHazelcastConfig()
-                            
.getProperty("hazelcast.invocation.retry.pause.millis");
+                            .getProperty(INVOCATION_RETRY_PAUSE.getName());
 
             int retryPause =
                     hazelcastRetryPause == null ? 500 : 
Integer.parseInt(hazelcastRetryPause);