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)