Rui Li created FLINK-21637:
------------------------------
Summary: Wrong results when filtering by timestamp type
Key: FLINK-21637
URL: https://issues.apache.org/jira/browse/FLINK-21637
Project: Flink
Issue Type: Bug
Components: Table SQL / Planner
Reporter: Rui Li
The following test can reproduce the issue:
{code}
@Test
def test(): Unit = {
TestCollectionTableFactory.reset()
TestCollectionTableFactory.initData(
Collections.singletonList(Row.of("a",
LocalDateTime.parse("2021-03-05T20:35:01.1"))))
tEnv.executeSql("create table src(s string,ts timestamp) with('connector' =
'COLLECTION')")
val results = CollectionUtil.iteratorToList(
tEnv.executeSql("select s from src where timestamp '2021-03-05 20:35:01'
= ts").collect())
assertEquals(0, results.size())
}
{code}
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
