zoucao created FLINK-20546:
------------------------------
Summary: Misuse of the method in KafkaDynamicTableFactoryTest
Key: FLINK-20546
URL: https://issues.apache.org/jira/browse/FLINK-20546
Project: Flink
Issue Type: Improvement
Components: Connectors / Kafka
Affects Versions: 1.12.0
Reporter: zoucao
hi all, I am reading something about DynamicTable Source/Sink Factory recently,
and one thing let me confused. In `KafkaDynamicTableFactoryTest`,
`getBasicSourceOptions()` and `getBasicSinkOptions()` are created for source
table and sink table, respectively. However, in the situation of validating
sink table, `getBasicSourceOptions()` is called, for example in method
`testSinkWithTopicListOrTopicPattern`、`testInvalidSinkSemantic` etc. Although
no exception is thrown, it also should be fixed. WDYT?
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
