[jira] [Created] (FLINK-20378) Watermark generation check TIMESTAMP_WITHOUT_TIME_ZONE

[Shang Yuanchun (Jira)]

wxmimperio created FLINK-20378:
----------------------------------

             Summary: Watermark generation check TIMESTAMP_WITHOUT_TIME_ZONE
                 Key: FLINK-20378
                 URL: https://issues.apache.org/jira/browse/FLINK-20378
             Project: Flink
          Issue Type: Improvement
          Components: Table SQL / Planner
    Affects Versions: 1.11.1
            Reporter: wxmimperio


 

 
{code:java}
 def generateWatermarkGenerator(
      config: TableConfig,
      inputType: RowType,
      watermarkExpr: RexNode): GeneratedWatermarkGenerator = {
    // validation
    val watermarkOutputType = FlinkTypeFactory.toLogicalType(watermarkExpr.getType)
    if (watermarkOutputType.getTypeRoot != LogicalTypeRoot.TIMESTAMP_WITHOUT_TIME_ZONE) {
      throw new CodeGenException(
        "WatermarkGenerator only accepts output data type of TIMESTAMP," +
          " but is " + watermarkOutputType)
    }
{code}
 

Why does watermark generation need to be detected as TIMESTAMP_WITHOUT_TIME_ZONE?

If I remove this check, what effect will it have on the watermark?

 

 

 

 



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