[jira] [Updated] (FLINK-11543) Type mismatch AssertionError in FilterJoinRule

["Timo Walther (JIRA)" <ji...@apache.org>]

     [ https://issues.apache.org/jira/browse/FLINK-11543?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Timo Walther updated FLINK-11543:
---------------------------------
    Affects Version/s: 1.7.1

> Type mismatch AssertionError in FilterJoinRule 
> -----------------------------------------------
>
>                 Key: FLINK-11543
>                 URL: https://issues.apache.org/jira/browse/FLINK-11543
>             Project: Flink
>          Issue Type: Bug
>          Components: Table API & SQL
>    Affects Versions: 1.7.1
>            Reporter: Timo Walther
>            Priority: Major
>         Attachments: Test.java
>
>
> The following problem is copied from the user mailing list:
> {code}
> Exception in thread "main" java.lang.AssertionError: mismatched type $5 TIMESTAMP(3)
>     at org.apache.calcite.rex.RexUtil$FixNullabilityShuttle.visitInputRef(RexUtil.java:2481)
>     at org.apache.calcite.rex.RexUtil$FixNullabilityShuttle.visitInputRef(RexUtil.java:2459)
>     at org.apache.calcite.rex.RexInputRef.accept(RexInputRef.java:112)
>     at org.apache.calcite.rex.RexShuttle.visitList(RexShuttle.java:151)
>     at org.apache.calcite.rex.RexShuttle.visitCall(RexShuttle.java:100)
>     at org.apache.calcite.rex.RexShuttle.visitCall(RexShuttle.java:34)
>     at org.apache.calcite.rex.RexCall.accept(RexCall.java:107)
>     at org.apache.calcite.rex.RexShuttle.apply(RexShuttle.java:279)
>     at org.apache.calcite.rex.RexShuttle.mutate(RexShuttle.java:241)
>     at org.apache.calcite.rex.RexShuttle.apply(RexShuttle.java:259)
>     at org.apache.calcite.rex.RexUtil.fixUp(RexUtil.java:1605)
>     at org.apache.calcite.rel.rules.FilterJoinRule.perform(FilterJoinRule.java:230)
>     at org.apache.calcite.rel.rules.FilterJoinRule$FilterIntoJoinRule.onMatch(FilterJoinRule.java:344)
>     at org.apache.calcite.plan.volcano.VolcanoRuleCall.onMatch(VolcanoRuleCall.java:212)
>     at org.apache.calcite.plan.volcano.VolcanoPlanner.findBestExp(VolcanoPlanner.java:646)
>     at org.apache.calcite.tools.Programs$RuleSetProgram.run(Programs.java:339)
>     at org.apache.flink.table.api.TableEnvironment.runVolcanoPlanner(TableEnvironment.scala:374)
>     at org.apache.flink.table.api.TableEnvironment.optimizeLogicalPlan(TableEnvironment.scala:292)
>     at org.apache.flink.table.api.StreamTableEnvironment.optimize(StreamTableEnvironment.scala:812)
>     at org.apache.flink.table.api.StreamTableEnvironment.translate(StreamTableEnvironment.scala:860)
>     at org.apache.flink.table.api.java.StreamTableEnvironment.toRetractStream(StreamTableEnvironment.scala:340)
>     at org.apache.flink.table.api.java.StreamTableEnvironment.toRetractStream(StreamTableEnvironment.scala:272)
>     at test.Test.main(Test.java:78) 
> {code}
> It sounds related to FLINK-10211. A runnable example is attached.
> See also: https://lists.apache.org/thread.html/9a9a979f4344111baf053a51ebfa2f2a0ba31e4d5a70e633dbcae254@%3Cuser.flink.apache.org%3E



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)