From 0db58800d33688519c14a90ef82e8e461abfcc20 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E5=A5=95=E5=86=B7?= <82279870+TangSiyang2001@users.noreply.github.com> Date: Mon, 27 Feb 2023 18:01:43 +0800 Subject: [PATCH] [fix](stmt-forward) fix result missing (#17173) --- .../src/main/java/org/apache/doris/qe/MasterOpExecutor.java | 4 ++-- 1 file changed, 2 insertions(+), 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 index f1837f6882..412e5533a4 100644 --- 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 @@ public class MasterOpExecutor { boolean isReturnToPool = false; try { - client.forward(params); + result = client.forward(params); isReturnToPool = true; } catch (TTransportException e) { // wrap the raw exception. @@ -146,7 +146,7 @@ public class MasterOpExecutor { } 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;