[
https://issues.apache.org/jira/browse/FLINK-37195?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
yux closed FLINK-37195.
-----------------------
Resolution: Resolved
It turns out to be caused by a miswritten projection expression typo.
Still need to add corresponding integration tests / E2e tests for FLINK-36647.
> TimestampAdd / TimestampDiff series function not available in cluster
> ---------------------------------------------------------------------
>
> Key: FLINK-37195
> URL: https://issues.apache.org/jira/browse/FLINK-37195
> Project: Flink
> Issue Type: Bug
> Components: Flink CDC
> Affects Versions: cdc-3.3.0
> Reporter: yux
> Priority: Major
>
> Currently, it's not possible to write Transform expressions with TimestampAdd
> / TimestampDiff built-in functions while job is being submitted to remote
> Flink cluster.
> The following exception will be thrown:
> Caused by: org.apache.calcite.sql.parser.impl.ParseException: Incorrect
> syntax near the keyword 'SECOND' at line 1, column 25.
> Was expecting one of:
> "ALL" ...
> "ARRAY" ...
> "CASE" ...
> "CURRENT" ...
> "CURRENT_CATALOG" ...
> "CURRENT_DATE" ...
> "CURRENT_DEFAULT_TRANSFORM_GROUP" ...
> "CURRENT_PATH" ...
> "CURRENT_ROLE" ...
> "CURRENT_SCHEMA" ...
> "CURRENT_TIME" ...
> "CURRENT_TIMESTAMP" ...
> "CURRENT_USER" ...
> "DATE" ...
> "DEFAULT" ...
> "DISTINCT" ...
> "EXISTS" ...
> "FALSE" ...
> "INTERVAL" ...
> "LOCALTIME" ...
> "LOCALTIMESTAMP" ...
> "MULTISET" ...
> "NEW" ...
> "NEXT" ...
> "NOT" ...
> "NULL" ...
> "PERIOD" ...
> "SESSION_USER" ...
> "SYSTEM_USER" ...
> "TIME" ...
> "TIMESTAMP" ...
> "TRUE" ...
> "UNIQUE" ...
> "UNKNOWN" ...
> "USER" ...
> "WITH" ...
> <UNSIGNED_INTEGER_LITERAL> ...
> <APPROX_NUMERIC_LITERAL> ...
> <DECIMAL_NUMERIC_LITERAL> ...
> <BINARY_STRING_LITERAL> ...
> <QUOTED_STRING> ...
> <PREFIXED_STRING_LITERAL> ...
> <UNICODE_STRING_LITERAL> ...
> <BIG_QUERY_DOUBLE_QUOTED_STRING> ...
> <BIG_QUERY_QUOTED_STRING> ...
> <LBRACE_D> ...
> <LBRACE_T> ...
> <LBRACE_TS> ...
> <LBRACE_FN> ...
> "?" ...
> "+" ...
> "-" ...
> <BRACKET_QUOTED_IDENTIFIER> ...
> <QUOTED_IDENTIFIER> ...
> <BACK_QUOTED_IDENTIFIER> ...
> <BIG_QUERY_BACK_QUOTED_IDENTIFIER> ...
> <HYPHENATED_IDENTIFIER> ...
> <IDENTIFIER> ...
> <UNICODE_QUOTED_IDENTIFIER> ...
> "TABLE" ...
> "CAST" ...
> "EXTRACT" ...
> "POSITION" ...
> "CONVERT" ...
> "TRANSLATE" ...
> "OVERLAY" ...
> "FLOOR" ...
> "CEIL" ...
> "CEILING" ...
> "SUBSTRING" ...
> "TRIM" ...
> "CLASSIFIER" ...
> "MATCH_NUMBER" ...
> "RUNNING" ...
> "PREV" ...
> "JSON_EXISTS" ...
> "JSON_VALUE" ...
> "JSON_QUERY" ...
> "JSON_OBJECT" ...
> "JSON_OBJECTAGG" ...
> "JSON_ARRAY" ...
> "JSON_ARRAYAGG" ...
> "SPECIFIC" ...
> "ABS" ...
> "AVG" ...
> "CARDINALITY" ...
> "CHAR" ...
> "CHAR_LENGTH" ...
> "CHARACTER_LENGTH" ...
> "COALESCE" ...
> "COLLECT" ...
> "COVAR_POP" ...
> "COVAR_SAMP" ...
> "CUME_DIST" ...
> "COUNT" ...
> "DENSE_RANK" ...
> "ELEMENT" ...
> "EVERY" ...
> "EXP" ...
> "FIRST_VALUE" ...
> "FUSION" ...
> "INTERSECTION" ...
> "GROUPING" ...
> "HOUR" ...
> "LAG" ...
> "LEAD" ...
> "LEFT" ...
> "LAST_VALUE" ...
> "LN" ...
> "LOWER" ...
> "MAX" ...
> "MIN" ...
> "MINUTE" ...
> "MOD" ...
> "MONTH" ...
> "NTH_VALUE" ...
> "NTILE" ...
> "NULLIF" ...
> "OCTET_LENGTH" ...
> "PERCENT_RANK" ...
> "PERCENTILE_CONT" ...
> "PERCENTILE_DISC" ...
> "POWER" ...
> "RANK" ...
> "REGR_COUNT" ...
> "REGR_SXX" ...
> "REGR_SYY" ...
> "RIGHT" ...
> "ROW_NUMBER" ...
> "SECOND" ...
> "SECOND" "(" ...
> "*" ...
> ")" ...
>
> at
> org.apache.calcite.sql.parser.impl.SqlParserImpl.convertException(SqlParserImpl.java:363)
>
> ~[blob_p-9d934193156d3920c143c7f233ee75551040ad35-6ee6ad5f1d77bfea9b172c8319b453fd:3.3-SNAPSHOT]
> at
> org.apache.calcite.sql.parser.impl.SqlParserImpl.normalizeException(SqlParserImpl.java:155)
>
> ~[blob_p-9d934193156d3920c143c7f233ee75551040ad35-6ee6ad5f1d77bfea9b172c8319b453fd:3.3-SNAPSHOT]
> at
> org.apache.calcite.sql.parser.SqlParser.handleException(SqlParser.java:156)
> ~[blob_p-9d934193156d3920c143c7f233ee75551040ad35-6ee6ad5f1d77bfea9b172c8319b453fd:3.3-SNAPSHOT]
> at org.apache.calcite.sql.parser.SqlParser.parseQuery(SqlParser.java:171)
> ~[blob_p-9d934193156d3920c143c7f233ee75551040ad35-6ee6ad5f1d77bfea9b172c8319b453fd:3.3-SNAPSHOT]
> at
> org.apache.flink.cdc.runtime.parser.TransformParser.parseSelect(TransformParser.java:189)
>
> ~[blob_p-9d934193156d3920c143c7f233ee75551040ad35-6ee6ad5f1d77bfea9b172c8319b453fd:3.3-SNAPSHOT]
> ... 30 more
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
