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 <[email protected]>
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: [email protected]
For additional commands, e-mail: [email protected]
