[jira] [Created] (FLINK-24168) Rowtime type is not correct for windowTableFunction or OverAggregate on Match because the output type does not updated after input rowtime attribute changed from rowtime to rowtime_ltz

["JING ZHANG (Jira)" <ji...@apache.org>]

JING ZHANG created FLINK-24168:
----------------------------------

             Summary: Rowtime type is not correct for windowTableFunction or OverAggregate on Match because the output type does not updated after input rowtime attribute changed from rowtime to rowtime_ltz
                 Key: FLINK-24168
                 URL: https://issues.apache.org/jira/browse/FLINK-24168
             Project: Flink
          Issue Type: Bug
          Components: Table SQL / Planner
    Affects Versions: 1.14.0
            Reporter: JING ZHANG


Rowtime type is not correct for windowTableFunction or OverAggregate on Match because the output type does not updated after input rowtime attribute changed from rowtime to rowtime_ltz in `RelTimeIndicator`.

The bug could be reproduced by the following two cases:
{code:java}
@Test
def testWindowTVFOnMatchRecognizeOnRowtimeLTZ(): Unit = {
  val sqlQuery =
    s"""
       |SELECT
       |  *
       |FROM Ticker
       |MATCH_RECOGNIZE (
       |  PARTITION BY symbol
       |  ORDER BY ts_ltz
       |  MEASURES
       |    A.price as price,
       |    A.tax as tax,
       |    MATCH_ROWTIME() as matchRowtime
       |  ONE ROW PER MATCH
       |  PATTERN (A)
       |  DEFINE
       |    A AS A.price > 0
       |) AS T
       |""".stripMargin
  val table = util.tableEnv.sqlQuery(sqlQuery)
  util.tableEnv.registerTable("T", table)
  val sqlQuery1 =
    s"""
       |SELECT *
       |FROM TABLE(TUMBLE(TABLE T, DESCRIPTOR(matchRowtime), INTERVAL '3' second))
       |""".stripMargin
  util.verifyRelPlanWithType(sqlQuery1)
}

@Test
def testOverWindowOnMatchRecognizeOnRowtimeLTZ(): Unit = {
  val sqlQuery =
    s"""
       |SELECT
       |  *
       |FROM Ticker
       |MATCH_RECOGNIZE (
       |  PARTITION BY symbol
       |  ORDER BY ts_ltz
       |  MEASURES
       |    A.price as price,
       |    A.tax as tax,
       |    MATCH_ROWTIME() as matchRowtime
       |  ONE ROW PER MATCH
       |  PATTERN (A)
       |  DEFINE
       |    A AS A.price > 0
       |) AS T
       |""".stripMargin
  val table = util.tableEnv.sqlQuery(sqlQuery)
  util.tableEnv.registerTable("T", table)
  val sqlQuery1 =
    """
      |SELECT
      |  symbol,
      |  price,
      |  tax,
      |  matchRowtime,
      |  SUM(price) OVER (
      |    PARTITION BY symbol ORDER BY matchRowtime RANGE UNBOUNDED PRECEDING) as price_sum
      |FROM T
    """.stripMargin
  util.verifyRelPlanWithType(sqlQuery1)
}

{code}
 



--
This message was sent by Atlassian Jira
(v8.3.4#803005)