This is an automated email from the ASF dual-hosted git repository.
rongr pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/pinot.git
The following commit(s) were added to refs/heads/master by this push:
new d22b4678f5 [cleanup][bugfix] remove useless check (#9587)
d22b4678f5 is described below
commit d22b4678f5e4a0436f03ff7b0927ecaeaa7dc2c1
Author: Rong Rong <[email protected]>
AuthorDate: Thu Oct 13 13:38:56 2022 -0700
[cleanup][bugfix] remove useless check (#9587)
* [cleanup] remove useless check
Co-authored-by: Rong Rong <[email protected]>
---
.../org/apache/pinot/query/planner/logical/RelToStageConverter.java | 4 ----
1 file changed, 4 deletions(-)
diff --git
a/pinot-query-planner/src/main/java/org/apache/pinot/query/planner/logical/RelToStageConverter.java
b/pinot-query-planner/src/main/java/org/apache/pinot/query/planner/logical/RelToStageConverter.java
index e45b24944e..97df437222 100644
---
a/pinot-query-planner/src/main/java/org/apache/pinot/query/planner/logical/RelToStageConverter.java
+++
b/pinot-query-planner/src/main/java/org/apache/pinot/query/planner/logical/RelToStageConverter.java
@@ -18,7 +18,6 @@
*/
package org.apache.pinot.query.planner.logical;
-import com.google.common.base.Preconditions;
import java.util.List;
import java.util.stream.Collectors;
import org.apache.calcite.rel.RelNode;
@@ -34,7 +33,6 @@ import org.apache.calcite.rel.logical.LogicalValues;
import org.apache.calcite.rel.type.RelDataType;
import org.apache.calcite.rel.type.RelDataTypeField;
import org.apache.calcite.rel.type.RelRecordType;
-import org.apache.calcite.rex.RexCall;
import org.apache.calcite.rex.RexLiteral;
import org.apache.pinot.common.utils.DataSchema;
import org.apache.pinot.query.planner.partitioning.FieldSelectionKeySelector;
@@ -118,8 +116,6 @@ public final class RelToStageConverter {
private static StageNode convertLogicalJoin(LogicalJoin node, int
currentStageId) {
JoinRelType joinType = node.getJoinType();
- Preconditions.checkState(node.getCondition() instanceof RexCall);
- RexCall joinCondition = (RexCall) node.getCondition();
// Parse out all equality JOIN conditions
JoinInfo joinInfo = node.analyzeCondition();
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
