database/doris
2
0
Fork 0
Code Issues Pull Requests Actions 3 Packages Projects Releases Wiki Activity

Revert "[Bug](log) add some log to find out bug (#16518)" (#17178)

Browse Source 
This reverts commit d1c6b8114053e8c754c979d8d3fbf5c880d361d2.
This commit is contained in:
Gabriel
2023-02-28 19:23:12 +08:00
committed by GitHub
parent 838107b8e8
commit 459874be50
5 changed files with 0 additions and 26 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
fe/fe-core/src/main/java/org/apache/doris/planner/AggregationNode.java
View File

@ -247,10 +247,6 @@ public class AggregationNode extends PlanNode {
super.debugString()).toString();
}
public boolean isTargetNode() {
return id.asInt() == 27 && needsFinalize;
}
@Override
protected void toThrift(TPlanNode msg) {
aggInfo.updateMaterializedSlots();

4
fe/fe-core/src/main/java/org/apache/doris/planner/PlanFragment.java
View File

@ -406,10 +406,6 @@ public class PlanFragment extends TreeNode<PlanFragment> {
return fragmentId;
}
public boolean hasTargetNode() {
return planRoot.isTargetNode();
}
public Set<RuntimeFilterId> getBuilderRuntimeFilterIds() {
return builderRuntimeFilterIds;
}

9
fe/fe-core/src/main/java/org/apache/doris/planner/PlanNode.java
View File

@ -207,15 +207,6 @@ public abstract class PlanNode extends TreeNode<PlanNode> implements PlanStats {
this.statsDeriveResult = statsDeriveResult;
}
public boolean isTargetNode() {
for (PlanNode node : children) {
if (node.isTargetNode()) {
return true;
}
}
return false;
}
/**
* Sets tblRefIds_, tupleIds_, and nullableTupleIds_.
* The default implementation is a no-op.

6
fe/fe-core/src/main/java/org/apache/doris/qe/Coordinator.java
View File

@ -317,12 +317,6 @@ public class Coordinator {
this.descTable = planner.getDescTable().toThrift();
}
for (PlanFragment fragment : fragments) {
if (fragment.hasTargetNode()) {
LOG.info("Log for ISSUE-16517: " + this.descTable.toString());
}
}
this.returnedAllResults = false;
this.enableShareHashTableForBroadcastJoin = context.getSessionVariable().enableShareHashTableForBroadcastJoin;
this.enablePipelineEngine = context.getSessionVariable().enablePipelineEngine;