diff --git a/dolphinscheduler-remote/src/main/java/org/apache/dolphinscheduler/rpc/future/RpcFuture.java b/dolphinscheduler-remote/src/main/java/org/apache/dolphinscheduler/rpc/future/RpcFuture.java index 64f2a0afd0..b824688a46 100644 --- a/dolphinscheduler-remote/src/main/java/org/apache/dolphinscheduler/rpc/future/RpcFuture.java +++ b/dolphinscheduler-remote/src/main/java/org/apache/dolphinscheduler/rpc/future/RpcFuture.java @@ -51,7 +51,7 @@ public class RpcFuture implements Future { @Override public RpcResponse get() throws InterruptedException, ExecutionException { - latch.await(-1, TimeUnit.SECONDS); + latch.await(5, TimeUnit.SECONDS); return response; }