Uploaded image for project: 'Flink'
  1. Flink
  2. FLINK-31090

Flink SQL fail to select INTERVAL

    XMLWordPrintableJSON

Details

    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

          Activity

            People

              Unassigned Unassigned
              luoyuxia luoyuxia
              Votes:
              0 Vote for this issue
              Watchers:
              3 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved: