From a63c2c6cbb9d8ff58e6b4acd78e3dfd7e39319f3 Mon Sep 17 00:00:00 2001 From: CalvinKirs Date: Mon, 25 Jan 2021 23:47:07 +0800 Subject: [PATCH] fix bug --- .../java/org/apache/dolphinscheduler/rpc/future/RpcFuture.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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; }