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)
