Wenkai Qi created FLINK-36636:
---------------------------------
Summary: Timestamp data can not be compared in cdc pipeline
transform
Key: FLINK-36636
URL: https://issues.apache.org/jira/browse/FLINK-36636
Project: Flink
Issue Type: Bug
Components: Flink CDC
Affects Versions: cdc-3.2.0
Reporter: Wenkai Qi
Timestamp data can not be compared in cdc pipeline transform.
When projecting or filtering code containing timestamp comparisons, the program
will encounter errors.
{code:java}
TO_TIMESTAMP('2024-01-01 00:00:00') < TO_TIMESTAMP('2024-08-01 00:00:00') {code}
Error:
{code:java}
org.apache.flink.api.common.InvalidProgramException: Expression cannot be
compiled. This is a bug. Please file an issue.
Expression: import static
org.apache.flink.cdc.runtime.functions.SystemFunctionUtils.*;toTimestamp("2024-01-01
00:00:00", __time_zone__) < toTimestamp("2024-08-01 00:00:00", __time_zone__)
? 1 : 0
...
...
Caused by: org.codehaus.commons.compiler.CompileException: Line 1, Column 176:
Operator "<" not allowed on reference operands {code}
There is currently a method that can be temporarily replaced, but I believe it
is not in line with user habits.
{code:java}
TIMESTAMP_DIFF('SECOND',TO_TIMESTAMP('2024-01-01 00:00:00') ,
TO_TIMESTAMP('2024-08-01 00:00:00')) > 0 {code}
Do we need to support comparing timestamps through relational operators, such as
{code:java}
> >= < <= {code}
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
