[doris] 09/13: [chore](topn-opt) temporary disable two phase read for `TableQueryPlanActionQ` (#22543)

[kxiao]

This is an automated email from the ASF dual-hosted git repository.

kxiao pushed a commit to branch branch-2.0
in repository https://gitbox.apache.org/repos/asf/doris.git

commit 33fce1a277d450af808c68ee4e143251e53631c1
Author: lihangyu <15605149...@163.com>
AuthorDate: Fri Aug 4 11:53:48 2023 +0800

    [chore](topn-opt) temporary disable two phase read for 
`TableQueryPlanActionQ` (#22543)
---
 .../java/org/apache/doris/httpv2/rest/TableQueryPlanAction.java     | 6 ++++++
 fe/fe-core/src/main/java/org/apache/doris/qe/SessionVariable.java   | 4 ++++
 2 files changed, 10 insertions(+)

diff --git 
a/fe/fe-core/src/main/java/org/apache/doris/httpv2/rest/TableQueryPlanAction.java
 
b/fe/fe-core/src/main/java/org/apache/doris/httpv2/rest/TableQueryPlanAction.java
index 033a03fa0b..6a34322f0e 100644
--- 
a/fe/fe-core/src/main/java/org/apache/doris/httpv2/rest/TableQueryPlanAction.java
+++ 
b/fe/fe-core/src/main/java/org/apache/doris/httpv2/rest/TableQueryPlanAction.java
@@ -122,6 +122,12 @@ public class TableQueryPlanAction extends 
RestBaseController {
             }
             table.readLock();
             try {
+                if (ConnectContext.get() != null
+                        && ConnectContext.get().getSessionVariable() != null) {
+                    // Disable some optimizations, since it's not fully 
supported
+                    // TODO support it
+                    
ConnectContext.get().getSessionVariable().setEnableTwoPhaseReadOpt(false);
+                }
                 // parse/analysis/plan the sql and acquire tablet distributions
                 handleQuery(ConnectContext.get(), fullDbName, tblName, sql, 
resultMap);
             } finally {
diff --git a/fe/fe-core/src/main/java/org/apache/doris/qe/SessionVariable.java 
b/fe/fe-core/src/main/java/org/apache/doris/qe/SessionVariable.java
index 12f8dc1bc8..afe30a3781 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/qe/SessionVariable.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/qe/SessionVariable.java
@@ -1192,6 +1192,10 @@ public class SessionVariable implements Serializable, 
Writable {
         return queryTimeoutS;
     }
 
+    public void setEnableTwoPhaseReadOpt(boolean enable) {
+        enableTwoPhaseReadOpt = enable;
+    }
+
     public int getMaxExecutionTimeMS() {
         return maxExecutionTimeMS;
     }


---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org
For additional commands, e-mail: commits-h...@doris.apache.org