(flink) branch master updated: [FLINK-36602][tests] Add pre Calcite 1.38.0 tests for CALCITE-7562 issue

[snuyanzin]

This is an automated email from the ASF dual-hosted git repository.

snuyanzin pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git


The following commit(s) were added to refs/heads/master by this push:
     new fa2678926fa [FLINK-36602][tests] Add pre Calcite 1.38.0 tests for 
CALCITE-7562 issue
fa2678926fa is described below

commit fa2678926fa7e626e6c7e44ec0da6b749dc602cd
Author: Sergey Nuyanzin <snuyan...@gmail.com>
AuthorDate: Fri May 29 21:05:54 2026 +0200

    [FLINK-36602][tests] Add pre Calcite 1.38.0 tests for CALCITE-7562 issue
---
 .../planner/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 5882aab687a..42d53d9ede1 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")))
+  }
 }