You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@doris.apache.org by kx...@apache.org on 2023/08/04 10:58:23 UTC
[doris] 09/13: [chore](topn-opt) temporary disable two phase read for `TableQueryPlanActionQ` (#22543)
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 <15...@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-unsubscribe@doris.apache.org
For additional commands, e-mail: commits-help@doris.apache.org