[
https://issues.apache.org/jira/browse/FLINK-37012?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu closed FLINK-37012.
------------------------------
Fix Version/s: cdc-3.3.0
Resolution: Fixed
fixed via master: f7f3901fa38a0e1074609545703d19e99601aa5a
> Fix exception caused by MetadataColumns causing argument type mismatch
> ----------------------------------------------------------------------
>
> Key: FLINK-37012
> URL: https://issues.apache.org/jira/browse/FLINK-37012
> Project: Flink
> Issue Type: Bug
> Components: Flink CDC
> Affects Versions: cdc-3.2.0, cdc-3.2.1
> Reporter: MOBIN
> Assignee: MOBIN
> Priority: Major
> Labels: pull-request-available
> Fix For: cdc-3.3.0
>
>
> pipelin.yml
> {code:java}
> transform:
> - source-table: testdb.cdc_test
> projection: id, concat(__table_name__,'_',id) as tbname_id
> primary-keys: id{code}
> When the id is not string type, the following exception is thrown
> {code:java}
> Caused by: java.lang.IllegalArgumentException: argument type mismatch
> at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
> at
> sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
> at
> sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
> at java.lang.reflect.Method.invoke(Method.java:497)
> at
> org.codehaus.janino.ExpressionEvaluator.evaluate(ExpressionEvaluator.java:541)
> at
> org.codehaus.janino.ExpressionEvaluator.evaluate(ExpressionEvaluator.java:533)
> at
> org.apache.flink.cdc.runtime.operators.transform.ProjectionColumnProcessor.evaluate(ProjectionColumnProcessor.java:99)
> at
> org.apache.flink.cdc.runtime.operators.transform.TransformProjectionProcessor.processData(TransformProjectionProcessor.java:154)
> {code}
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
