[jira] [Created] (FLINK-36982) Failed to run pipeline if using `DATE_FORMAT(NOW(), 'yyyy-MM-dd') as datetime` in

["Yanquan Lv (Jira)" <ji...@apache.org>]

Yanquan Lv created FLINK-36982:
----------------------------------

             Summary: Failed to run pipeline if using `DATE_FORMAT(NOW(), 'yyyy-MM-dd') as datetime` in
                 Key: FLINK-36982
                 URL: https://issues.apache.org/jira/browse/FLINK-36982
             Project: Flink
          Issue Type: New Feature
          Components: Flink CDC
    Affects Versions: cdc-3.2.1, cdc-3.2.0
            Reporter: Yanquan Lv


How to produce:
{code:java}
source:
  type: values

sink:
  type: values

transform: 
  projection: DATE_FORMAT(CURRENT_TIMESTAMP, 'yyyy-MM-dd') as datetime {code}
org.apache.flink.util.FlinkRuntimeException: 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.*;dateFormat(currentTimestamp(__epoch_time__), "yyyy-MM-dd")
 
at org.apache.flink.cdc.runtime.operators.transform.TransformExpressionCompiler.compileExpression(TransformExpressionCompiler.java:84)
at org.apache.flink.cdc.runtime.operators.transform.ProjectionColumnProcessor.<init>(ProjectionColumnProcessor.java:71)
at org.apache.flink.cdc.runtime.operators.transform.ProjectionColumnProcessor.of(ProjectionColumnProcessor.java:83)

Howerver, the following job file can work well:
{code:java}
source:
  type: values

sink:
  type: values
 
transform: 
  projection: DATE_FORMAT(LOCALTIMESTAMP, 'yyyy-MM-dd') as datetime {code}




 

 



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