From d643f1a9797fd0917614b677fe7707fb797c5863 Mon Sep 17 00:00:00 2001
From: qianye <wuxingcan.wxc@alibaba-inc.com>
Date: Thu, 25 Sep 2025 14:42:46 +0800
Subject: [PATCH] fix

---
 .../org/apache/rocketmq/remoting/netty/NettyRemotingClient.java  | 1 +
 1 file changed, 1 insertion(+)

diff --git a/remoting/src/main/java/org/apache/rocketmq/remoting/netty/NettyRemotingClient.java b/remoting/src/main/java/org/apache/rocketmq/remoting/netty/NettyRemotingClient.java
index 5dcc346ef52..973d229befe 100644
--- a/remoting/src/main/java/org/apache/rocketmq/remoting/netty/NettyRemotingClient.java
+++ b/remoting/src/main/java/org/apache/rocketmq/remoting/netty/NettyRemotingClient.java
@@ -746,6 +746,7 @@ public void invokeAsync(String addr, RemotingCommand request, long timeoutMillis
                     long costTime = System.currentTimeMillis() - beginStartTime;
                     if (timeoutMillis < costTime) {
                         invokeCallback.operationFail(new RemotingTooMuchRequestException("invokeAsync call the addr[" + channelRemoteAddr + "] timeout"));
+                        return;
                     }
                     this.invokeAsyncImpl(channel, request, timeoutMillis - costTime, new InvokeCallbackWrapper(invokeCallback, addr));
                 } else {