4

xinyiZzz · Dec 17, 2024 · 47414e2 · 47414e2
1 parent 4b6a18d
commit 47414e2
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 7 deletions.
diff --git a/fe/fe-core/src/main/java/org/apache/doris/qe/QeProcessorImpl.java b/fe/fe-core/src/main/java/org/apache/doris/qe/QeProcessorImpl.java
@@ -272,10 +272,10 @@ public TReportExecStatusResult reportExecStatus(TReportExecStatusParams params,
         }
         ConnectContext ctx = info.getConnectContext();
         if (ctx.getConnectType() == ConnectType.ARROW_FLIGHT_SQL && params.isDone()) {
-            // `params.isDone` may be true in multiple reportExecStatus.
-            if (ctx.getIsFlightSqlConnectProcessorClose() && !ctx.getFinalizeArrowFlightSqlRequestFinished()) {
-                ctx.finalizeArrowFlightSqlRequest();
-            }
+            // // `params.isDone` may be true in multiple reportExecStatus.
+            // if (ctx.getIsFlightSqlConnectProcessorClose() && !ctx.getFinalizeArrowFlightSqlRequestFinished()) {
+            //     ctx.finalizeArrowFlightSqlRequest();
+            // }
             ctx.setIsExecStatusDone();
         }
         result.setStatus(new TStatus(TStatusCode.OK));

diff --git a/fe/fe-core/src/main/java/org/apache/doris/service/arrowflight/FlightSqlConnectProcessor.java b/fe/fe-core/src/main/java/org/apache/doris/service/arrowflight/FlightSqlConnectProcessor.java
@@ -193,9 +193,9 @@ public void fetchArrowFlightSchema(int timeoutMs) {
 
     @Override
     public void close() throws Exception {
-        if (ctx.getIsExecStatusDone()) {
-            ctx.finalizeArrowFlightSqlRequest();
-        }
+        // if (ctx.getIsExecStatusDone()) {
+        ctx.finalizeArrowFlightSqlRequest();
+        // }
         ctx.setIsFlightSqlConnectProcessorClose();
         ConnectContext.remove();
     }