You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@flink.apache.org by "Rui Li (Jira)" <ji...@apache.org> on 2021/03/05 12:52:00 UTC
[jira] [Created] (FLINK-21637) Wrong results when filtering by
timestamp type
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)