[fix](stmt-forward) fix result missing (apache#17173)

morningman · Feb 27, 2023 · 0db5880 · 0db5880
1 parent d5b1d34
commit 0db5880
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/fe/fe-core/src/main/java/org/apache/doris/qe/MasterOpExecutor.java b/fe/fe-core/src/main/java/org/apache/doris/qe/MasterOpExecutor.java
@@ -129,7 +129,7 @@ private void forward() throws Exception {
 
         boolean isReturnToPool = false;
         try {
-            client.forward(params);
+            result = client.forward(params);
             isReturnToPool = true;
         } catch (TTransportException e) {
             // wrap the raw exception.
@@ -146,7 +146,7 @@ private void forward() throws Exception {
             } else {
                 LOG.warn("Forward statement " + ctx.getStmtId() + " to Master " + thriftAddress + " twice", e);
                 try {
-                    client.forward(params);
+                    result = client.forward(params);
                     isReturnToPool = true;
                 } catch (TException ex) {
                     throw exception;