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)