From 110652caa1c7db79af565b905c970e814596e906 Mon Sep 17 00:00:00 2001 From: Sergey Nuyanzin Date: Wed, 27 May 2026 09:42:35 +0200 Subject: [PATCH] [FLINK-36602][tests] Add pre Calcite 1.38.0 tests for CALCITE-7562 issue --- .../runtime/batch/sql/CalcITCase.scala | 35 +++++++++++++++++++ 1 file changed, 35 insertions(+) diff --git a/flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/planner/runtime/batch/sql/CalcITCase.scala b/flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/planner/runtime/batch/sql/CalcITCase.scala index 5882aab687acb..42d53d9ede176 100644 --- a/flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/planner/runtime/batch/sql/CalcITCase.scala +++ b/flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/planner/runtime/batch/sql/CalcITCase.scala @@ -2348,4 +2348,39 @@ class CalcITCase extends BatchTestBase { Seq(row(0, 1), row(1, 2), row(2, 3)) ); } + + @Test + def testDateColumnInListWithStringLiterals(): Unit = { + val data = Seq( + row(localDate("2000-06-30"), "a"), + row(localDate("2000-09-27"), "b"), + row(localDate("2000-11-17"), "c"), + row(localDate("2001-01-01"), "d")) + registerCollection( + "DateTable", + data, + new RowTypeInfo(LOCAL_DATE, STRING_TYPE_INFO), + "d_date, val") + + checkResult( + "SELECT val FROM DateTable WHERE d_date IN ('2000-06-30', '2000-09-27', '2000-11-17')", + Seq(row("a"), row("b"), row("c"))) + } + + @Test + def testTimestampColumnInListWithStringLiterals(): Unit = { + val data = Seq( + row(localDateTime("2000-06-30 12:00:00"), "a"), + row(localDateTime("2000-09-27 12:00:00"), "b"), + row(localDateTime("2001-01-01 12:00:00"), "c")) + registerCollection( + "TimestampTable", + data, + new RowTypeInfo(LOCAL_DATE_TIME, STRING_TYPE_INFO), + "ts, val") + + checkResult( + "SELECT val FROM TimestampTable WHERE ts IN ('2000-06-30 12:00:00', '2000-09-27 12:00:00')", + Seq(row("a"), row("b"))) + } }