diff --git a/fe/fe-core/src/main/java/org/apache/doris/analysis/ExprSubstitutionMap.java b/fe/fe-core/src/main/java/org/apache/doris/analysis/ExprSubstitutionMap.java index 35077b05f99e1c..2afe97523f018d 100644 --- a/fe/fe-core/src/main/java/org/apache/doris/analysis/ExprSubstitutionMap.java +++ b/fe/fe-core/src/main/java/org/apache/doris/analysis/ExprSubstitutionMap.java @@ -279,17 +279,21 @@ public String debugString() { * and that all rhs exprs are analyzed. */ private void verify() { - for (int i = 0; i < lhs_.size(); ++i) { - for (int j = i + 1; j < lhs_.size(); ++j) { - if (lhs_.get(i).equals(lhs_.get(j))) { - if (LOG.isTraceEnabled()) { - LOG.trace("verify: smap=" + this.debugString()); + // This method is very very time consuming, especially when planning large complex query. + // So disable it by default. + if (LOG.isDebugEnabled()) { + for (int i = 0; i < lhs_.size(); ++i) { + for (int j = i + 1; j < lhs_.size(); ++j) { + if (lhs_.get(i).equals(lhs_.get(j))) { + if (LOG.isTraceEnabled()) { + LOG.trace("verify: smap=" + this.debugString()); + } + // TODO(zc): partition by k1, order by k1, there is failed. + // Preconditions.checkState(false); } - // TODO(zc): partition by k1, order by k1, there is failed. - // Preconditions.checkState(false); } + Preconditions.checkState(!checkAnalyzed_ || rhs_.get(i).isAnalyzed()); } - Preconditions.checkState(!checkAnalyzed_ || rhs_.get(i).isAnalyzed()); } } diff --git a/fe/fe-core/src/main/java/org/apache/doris/qe/Coordinator.java b/fe/fe-core/src/main/java/org/apache/doris/qe/Coordinator.java index cd8d07828cab31..9e806fa05a1062 100644 --- a/fe/fe-core/src/main/java/org/apache/doris/qe/Coordinator.java +++ b/fe/fe-core/src/main/java/org/apache/doris/qe/Coordinator.java @@ -150,8 +150,6 @@ public class Coordinator { // copied from TQueryExecRequest; constant across all fragments private TDescriptorTable descTable; - private Set alreadySentBackendIds = Sets.newHashSet(); - // Why do we use query global? // When `NOW()` function is in sql, we need only one now(), // but, we execute `NOW()` distributed. @@ -390,7 +388,6 @@ public void clearExportStatus() { } this.exportFiles.clear(); this.needCheckBackendExecStates.clear(); - this.alreadySentBackendIds.clear(); } finally { lock.unlock(); } @@ -716,9 +713,6 @@ private void waitRpc(List