[jira] [Created] (FLINK-20942) Digest of FLOAT literals throws UnsupportedOperationException

[Shang Yuanchun (Jira)]

Timo Walther created FLINK-20942:
------------------------------------

             Summary: Digest of FLOAT literals throws UnsupportedOperationException
                 Key: FLINK-20942
                 URL: https://issues.apache.org/jira/browse/FLINK-20942
             Project: Flink
          Issue Type: Bug
          Components: Table SQL / Planner
            Reporter: Timo Walther


The recent refactoring of Calcite's digests might have caused a regression for FLOAT literals. {{org.apache.calcite.rex.RexLiteral#appendAsJava}} throws a UnsupportedOperationException for the following query:

{code}
def main(args: Array[String]): Unit = {
    val env = StreamExecutionEnvironment.getExecutionEnvironment
    val source = env.fromElements(
      (1.0f, 11.0f, 12.0f),
      (2.0f, 21.0f, 22.0f),
      (3.0f, 31.0f, 32.0f),
      (4.0f, 41.0f, 42.0f),
      (5.0f, 51.0f, 52.0f)
    )
    val settings = EnvironmentSettings.newInstance()
        .inStreamingMode()
        .useBlinkPlanner()
        .build()
    val tEnv = StreamTableEnvironment.create(env, settings)
    tEnv.createTemporaryView("myTable", source, $("id"), $("f1"), $("f2"))
    val query =
      """
        |select * from myTable where id in (1.0, 2.0, 3.0)
        |""".stripMargin
    tEnv.executeSql(query).print()
}
{code}



--
This message was sent by Atlassian Jira
(v8.3.4#803005)