This is an automated email from the ASF dual-hosted git repository. zouxinyi pushed a commit to branch branch-2.1 in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/branch-2.1 by this push: new b39358fd0a7 [Fix](branch-2.1) Fix arrow-flight-sql to use pipeline (#45661) b39358fd0a7 is described below commit b39358fd0a7bb47e92f166b6ed590723bdf0bdc8 Author: Xinyi Zou <zouxi...@selectdb.com> AuthorDate: Fri Dec 20 11:22:15 2024 +0800 [Fix](branch-2.1) Fix arrow-flight-sql to use pipeline (#45661) ### What problem does this PR solve? Fix arrow-flight-sql to use pipeline --- .../doris/service/arrowflight/sessions/FlightSessionsManager.java | 2 -- 1 file changed, 2 deletions(-) diff --git a/fe/fe-core/src/main/java/org/apache/doris/service/arrowflight/sessions/FlightSessionsManager.java b/fe/fe-core/src/main/java/org/apache/doris/service/arrowflight/sessions/FlightSessionsManager.java index 9c3871af5d3..2c3a5258cc4 100644 --- a/fe/fe-core/src/main/java/org/apache/doris/service/arrowflight/sessions/FlightSessionsManager.java +++ b/fe/fe-core/src/main/java/org/apache/doris/service/arrowflight/sessions/FlightSessionsManager.java @@ -49,8 +49,6 @@ public interface FlightSessionsManager { ConnectContext connectContext = new FlightSqlConnectContext(peerIdentity); connectContext.setEnv(Env.getCurrentEnv()); connectContext.setStartTime(); - connectContext.getSessionVariable().setEnablePipelineEngine(false); // TODO - connectContext.getSessionVariable().setEnablePipelineXEngine(false); // TODO connectContext.setQualifiedUser(userIdentity.getQualifiedUser()); connectContext.setCurrentUserIdentity(userIdentity); connectContext.setRemoteIP(remoteIP); --------------------------------------------------------------------- To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org For additional commands, e-mail: commits-h...@doris.apache.org