This is an automated email from the ASF dual-hosted git repository.
liujun pushed a commit to branch 3.x-dev
in repository https://gitbox.apache.org/repos/asf/incubator-dubbo.git
The following commit(s) were added to refs/heads/3.x-dev by this push:
new ad09f7a does not need to get timeout.
ad09f7a is described below
commit ad09f7a8717b89c676a8c8e8ba2b19ba9cb02e3a
Author: ken.lj <[email protected]>
AuthorDate: Thu May 23 12:57:52 2019 +0800
does not need to get timeout.
---
.../main/java/org/apache/dubbo/rpc/protocol/AsyncToSyncInvoker.java | 3 +--
1 file changed, 1 insertion(+), 2 deletions(-)
diff --git
a/dubbo-rpc/dubbo-rpc-api/src/main/java/org/apache/dubbo/rpc/protocol/AsyncToSyncInvoker.java
b/dubbo-rpc/dubbo-rpc-api/src/main/java/org/apache/dubbo/rpc/protocol/AsyncToSyncInvoker.java
index 9f1725d..5c06b4e 100644
---
a/dubbo-rpc/dubbo-rpc-api/src/main/java/org/apache/dubbo/rpc/protocol/AsyncToSyncInvoker.java
+++
b/dubbo-rpc/dubbo-rpc-api/src/main/java/org/apache/dubbo/rpc/protocol/AsyncToSyncInvoker.java
@@ -27,7 +27,6 @@ import org.apache.dubbo.rpc.RpcException;
import org.apache.dubbo.rpc.RpcInvocation;
import java.util.concurrent.ExecutionException;
-import java.util.concurrent.TimeUnit;
/**
* This class will work as a wrapper wrapping outside of each protocol invoker.
@@ -52,7 +51,7 @@ public class AsyncToSyncInvoker<T> implements Invoker<T> {
try {
if (InvokeMode.SYNC ==
((RpcInvocation)invocation).getInvokeMode()) {
-
asyncResult.get(invoker.getUrl().getMethodParameter(invocation.getMethodName(),
"timeout", 1000), TimeUnit.MILLISECONDS);
+ asyncResult.get();
}
} catch (InterruptedException e) {
throw new RpcException("Interrupted unexpectedly while waiting for
remoting result to return! method: " + invocation.getMethodName() + ",
provider: " + getUrl() + ", cause: " + e.getMessage(), e);