Github user twalthr commented on a diff in the pull request:
https://github.com/apache/flink/pull/6323#discussion_r202506494
--- Diff:
flink-libraries/flink-sql-client/src/main/java/org/apache/flink/table/client/config/SourceSink.java
---
@@ -51,16 +51,10 @@ public void addProperties(DescriptorProperties
properties) {
}
public Source toSource() {
- final Map<String, String> newProperties = new
HashMap<>(properties);
- newProperties.replace(TableDescriptorValidator.TABLE_TYPE(),
-
TableDescriptorValidator.TABLE_TYPE_VALUE_SOURCE());
--- End diff --
The table type is a concept of the SQL Client and should not be part of the
table descriptor.
---
