Github user pnowojski commented on a diff in the pull request:
https://github.com/apache/flink/pull/6323#discussion_r202520986
--- 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 --
I'm just asking because I can not find what code has replaced them. Or
there were some dead code?
---
