Hi @yanghua, I think this is the problem of CsvTableSource and Sink factory. We can resolve this by simply add a SUPPORT_MODE with value "update-mode" in CsvValidator and add it into CsvTableSourceFactoryBase and CsvTableSinkFactoryBase's supportedProperties method.
[ Full content available at: https://github.com/apache/flink/pull/6675 ] This message was relayed via gitbox.apache.org for [email protected]
