Ahmed Hamdy created FLINK-26058:
-----------------------------------
Summary: 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
{{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)
