MOBIN created FLINK-37012:
-----------------------------
Summary: 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.1, cdc-3.2.0
Reporter: MOBIN
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)
