[incubator-seatunnel] branch st-engine updated: [Engine][Task] Fix task running error. (#2504)

[fa...@apache.org]

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

fanjia pushed a commit to branch st-engine
in repository https://gitbox.apache.org/repos/asf/incubator-seatunnel.git


The following commit(s) were added to refs/heads/st-engine by this push:
     new a80f1a848 [Engine][Task] Fix task running error. (#2504)
a80f1a848 is described below

commit a80f1a84865ed9adc1cbcaa2f4f3166096a24d5e
Author: Hisoka <fa...@qq.com>
AuthorDate: Mon Aug 22 22:42:47 2022 +0800

    [Engine][Task] Fix task running error. (#2504)
---
 .../engine/server/task/operation/source/SourceRegisterOperation.java   | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git a/seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/task/operation/source/SourceRegisterOperation.java b/seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/task/operation/source/SourceRegisterOperation.java
index 3c78206d5..e570aeb0c 100644
--- a/seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/task/operation/source/SourceRegisterOperation.java
+++ b/seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/task/operation/source/SourceRegisterOperation.java
@@ -38,6 +38,7 @@ import java.io.IOException;
 public class SourceRegisterOperation extends Operation implements IdentifiedDataSerializable {
 
     private static final int RETRY_TIME = 5;
+    private static final int RETRY_TIME_OUT = 2000;
 
     private TaskLocation readerTaskID;
     private TaskLocation enumeratorTaskID;
@@ -60,7 +61,7 @@ public class SourceRegisterOperation extends Operation implements IdentifiedData
             task.receivedReader(readerTaskID, readerAddress);
             return null;
         }, new RetryUtils.RetryMaterial(RETRY_TIME, true,
-                exception -> exception instanceof NullPointerException));
+                exception -> exception instanceof NullPointerException, RETRY_TIME_OUT));
 
     }