[
https://issues.apache.org/jira/browse/FLINK-36958?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
MOBIN updated FLINK-36958:
--------------------------
Description:
When using Format Options in pipeline, such as
debezium-json.encode.decimal-as-plain-number, an exception of Unsupported
options will be thrown
{code:java}
source:
type: mysql
sink:
type: kafka
....
value.format: debezium-json
debezium-json.encode.decimal-as-plain-number: true{code}
{code:java}
Exception in thread "main" org.apache.flink.table.api.ValidationException:
Unsupported options found for 'kafka'.
Unsupported options:
debezium-json.encode.decimal-as-plain-number
Supported options:
sink.custom-header
value.format
sink.add-tableId-to-header-enabled
key.format
topic
sink.delivery-guarantee
partition.strategy
{code}
was:
When using Format Options in pipeline, such as
debezium-json.encode.decimal-as-plain-number, an exception of Unsupported
options will be thrown
{code:java}
source:
type: mysql
sink:
type: kafka
....
value.format: debezium-json
debezium-json.encode.decimal-as-plain-number: true{code}
{code:java}
Exception in thread "main" org.apache.flink.table.api.ValidationException:
Unsupported options found for 'kafka'.
Unsupported options:
debezium-json.encode.decimal-as-plain-number
Supported options:
sink.custom-header
value.format
sink.add-tableId-to-header-enabled
key.format
topic
sink.delivery-guarantee
partition.strategy
{code}
> Support pipeline-connector-kafka to reuse csv, canal-json and debezium-json
> Format Options
> ------------------------------------------------------------------------------------------
>
> Key: FLINK-36958
> URL: https://issues.apache.org/jira/browse/FLINK-36958
> Project: Flink
> Issue Type: Bug
> Components: Flink CDC
> Affects Versions: cdc-3.2.0
> Reporter: MOBIN
> Priority: Major
>
> When using Format Options in pipeline, such as
> debezium-json.encode.decimal-as-plain-number, an exception of Unsupported
> options will be thrown
> {code:java}
> source:
> type: mysql
> sink:
> type: kafka
> ....
> value.format: debezium-json
> debezium-json.encode.decimal-as-plain-number: true{code}
> {code:java}
> Exception in thread "main" org.apache.flink.table.api.ValidationException:
> Unsupported options found for 'kafka'.
> Unsupported options:
> debezium-json.encode.decimal-as-plain-number
> Supported options:
> sink.custom-header
> value.format
> sink.add-tableId-to-header-enabled
> key.format
> topic
> sink.delivery-guarantee
> partition.strategy
> {code}
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
