haishui created FLINK-35497:
-------------------------------

             Summary: The wrong enum value was used to get month in 
timestampDiff
                 Key: FLINK-35497
                 URL: https://issues.apache.org/jira/browse/FLINK-35497
             Project: Flink
          Issue Type: Bug
          Components: Flink CDC
    Affects Versions: cdc-3.1.0
            Reporter: haishui


In 
[SystemFunctionUtils#timestampDiff](https://github.com/apache/flink-cdc/blob/master/flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/functions/SystemFunctionUtils.java#L125):
 

{code:java}
case "MONTH":
    return to.get(Calendar.YEAR) * 12
            + to.get(Calendar.MONDAY)
            - (from.get(Calendar.YEAR) * 12 + from.get(Calendar.MONDAY)); {code}
The Calendar.MONDAY can be replaced with Calendar.MONTH.

This does not affect the calculation results, because Calendar.MONDAY = 
Calendar.MONTH = 2.

 



--
This message was sent by Atlassian Jira
(v8.20.10#820010)

Reply via email to