[CALCITE-2930] IllegalStateException when FilterCorrelateRule matches a SEMI or ANTI Correlate

• Type: Bug
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 1.18.0, 1.19.0
• Fix Version/s: 1.20.0
• Labels: pull-request-available
• Assignee: Ruben Q L
• Reporter: Ruben Q L
• Created: 18/Mar/19 11:06
• Updated: 24/Jun/19 15:01
• Resolved: 02/Apr/19 17:09

Description

FilterCorrelateRule#onMatch method executes the following:

public void onMatch(RelOptRuleCall call) {
    final Filter filter = call.rel(0);
    final Correlate corr = call.rel(1);
    ...
    RelOptUtil.classifyFilters(
        corr,
        aboveFilters,
        JoinRelType.INNER,
        false,
        !corr.getJoinType().toJoinType().generatesNullsOnLeft(), // *** HERE!
        !corr.getJoinType().toJoinType().generatesNullsOnRight(), // *** HERE!
        aboveFilters,
        leftFilters,
        rightFilters);
    ...

If the Correlate object has SemiJoinType SEMI (or ANTI), the corr.getJoinType().toJoinType() will throw a IllegalStateException:

Caused by: java.lang.IllegalStateException: Unable to convert SEMI to JoinRelType
	at org.apache.calcite.sql.SemiJoinType.toJoinType(SemiJoinType.java:83)
	at org.apache.calcite.rel.rules.FilterCorrelateRule.onMatch(FilterCorrelateRule.java:89)
	at org.apache.calcite.plan.volcano.VolcanoRuleCall.onMatch(VolcanoRuleCall.java:205)

Issue Links

• links to: GitHub Pull Request #1112