[
https://issues.apache.org/jira/browse/FLINK-26058?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ahmed Hamdy updated FLINK-26058:
--------------------------------
Description:
h2.Description
{{KinesisDynamicTableFactory}} implements {{DynamicTableSourceFactory}} while
{{KinesisDynamicTableSinkFactory}} implements {{DynamicTableSinkFactory}},
however {{KinesisDynamicTableFactory}} adds {{SINK_PARTITIONER}} and
{{SINK_PARTITION_DELIMITER}} options specific to sink in optional table options.
was:
{{h2. Description
KinesisDynamicTableFactory}} implements {{DynamicTableSourceFactory}} while
{{KinesisDynamicTableSinkFactory}} implements {{DynamicTableSinkFactory,
however KinesisDynamicTableFactory adds {{SINK_PARTITIONER}}}} and
{{SINK_PARTITION_DELIMITER}} options specific to sink in optional table options.
> KinesisDynamicTableFactory implements DynamicSourceFactory but uses sink
> options
> --------------------------------------------------------------------------------
>
> Key: FLINK-26058
> URL: https://issues.apache.org/jira/browse/FLINK-26058
> Project: Flink
> Issue Type: Bug
> Components: Connectors / Kinesis
> Reporter: Ahmed Hamdy
> Priority: Major
>
> h2.Description
> {{KinesisDynamicTableFactory}} implements {{DynamicTableSourceFactory}} while
> {{KinesisDynamicTableSinkFactory}} implements {{DynamicTableSinkFactory}},
> however {{KinesisDynamicTableFactory}} adds {{SINK_PARTITIONER}} and
> {{SINK_PARTITION_DELIMITER}} options specific to sink in optional table
> options.
--
This message was sent by Atlassian Jira
(v8.20.1#820001)
