Details
-
Bug
-
Status: Closed
-
Major
-
Resolution: Fixed
-
None
-
None
Description
Can be reproduce in CalcITCase with the following code:
@Test def testSelectInterval(): Unit = { checkResult("SELECT INTERVAL 2 DAY", data3) }
It'll throw the exception:
org.apache.flink.table.planner.codegen.CodeGenException: Interval expression type expected.
at org.apache.flink.table.planner.codegen.CodeGenUtils$.requireTimeInterval(CodeGenUtils.scala:419)
at org.apache.flink.table.planner.codegen.ExprCodeGenerator.generateCallExpression(ExprCodeGenerator.scala:549)
at org.apache.flink.table.planner.codegen.ExprCodeGenerator.visitCall(ExprCodeGenerator.scala:490)
at org.apache.flink.table.planner.codegen.ExprCodeGenerator.visitCall(ExprCodeGenerator.scala:57)
at org.apache.calcite.rex.RexCall.accept(RexCall.java:189)
at org.apache.flink.table.planner.codegen.ExprCodeGenerator.generateExpression(ExprCodeGenerator.scala:143)
at org.apache.flink.table.planner.codegen.ExpressionReducer.$anonfun$reduce$2(ExpressionReducer.scala:81)
at scala.collection.immutable.List.map(List.scala:282)
at org.apache.flink.table.planner.codegen.ExpressionReducer.reduce(ExpressionReducer.scala:81)
Attachments
Issue Links
- is fixed by
-
FLINK-31279 Fix MULTIPLY(TIMES) function doesn't support interval types
- Closed