This is an automated email from the ASF dual-hosted git repository.
albumenj pushed a commit to branch 3.1
in repository https://gitbox.apache.org/repos/asf/dubbo.git
The following commit(s) were added to refs/heads/3.1 by this push:
new 59a62a66b2 Revert clear response operation of timeoutfilter (#11562)
59a62a66b2 is described below
commit 59a62a66b2491d9b8359f0c230813ec4c387f12d
Author: huazhongming <[email protected]>
AuthorDate: Wed Feb 15 13:36:01 2023 +0800
Revert clear response operation of timeoutfilter (#11562)
* revert clear response operation of timeoutfilter
Signed-off-by: crazyhzm <[email protected]>
* remove useless import
Signed-off-by: crazyhzm <[email protected]>
---------
Signed-off-by: crazyhzm <[email protected]>
---
.../src/main/java/org/apache/dubbo/rpc/filter/TimeoutFilter.java | 2 --
1 file changed, 2 deletions(-)
diff --git
a/dubbo-rpc/dubbo-rpc-api/src/main/java/org/apache/dubbo/rpc/filter/TimeoutFilter.java
b/dubbo-rpc/dubbo-rpc-api/src/main/java/org/apache/dubbo/rpc/filter/TimeoutFilter.java
index 90e7ef9b4d..f4dae94073 100644
---
a/dubbo-rpc/dubbo-rpc-api/src/main/java/org/apache/dubbo/rpc/filter/TimeoutFilter.java
+++
b/dubbo-rpc/dubbo-rpc-api/src/main/java/org/apache/dubbo/rpc/filter/TimeoutFilter.java
@@ -20,7 +20,6 @@ import org.apache.dubbo.common.constants.CommonConstants;
import org.apache.dubbo.common.extension.Activate;
import org.apache.dubbo.common.logger.ErrorTypeAwareLogger;
import org.apache.dubbo.common.logger.LoggerFactory;
-import org.apache.dubbo.rpc.AppResponse;
import org.apache.dubbo.rpc.Filter;
import org.apache.dubbo.rpc.Invocation;
import org.apache.dubbo.rpc.Invoker;
@@ -51,7 +50,6 @@ public class TimeoutFilter implements Filter, Filter.Listener
{
if (obj != null) {
TimeoutCountDown countDown = (TimeoutCountDown) obj;
if (countDown.isExpired()) {
- ((AppResponse) appResponse).clear(); // clear response in case
of timeout.
if (logger.isWarnEnabled()) {
logger.warn(PROXY_TIMEOUT_REQUEST, "", "", "invoke timed
out. method: " + invocation.getMethodName() +
" url is " + invoker.getUrl() + ", invoke elapsed " +
countDown.elapsedMillis() + " ms.");