Efrat19 opened a new pull request, #207: URL: https://github.com/apache/flink-connector-kafka/pull/207
`UpsertKafkaDynamicTableFactoryTest#testTableSourceWithPartitionDiscovery` will fail without the added change to `UpsertKafkaDynamicTableFactory`: ``` Caused by: org.apache.flink.table.api.ValidationException: Unsupported options found for 'upsert-kafka'. Unsupported options: scan.topic-partition-discovery.interval Supported options: connector key.fields-prefix key.format key.test-format.changelog-mode key.test-format.delimiter key.test-format.deprecated-delimiter (deprecated) key.test-format.fail-on-missing key.test-format.fallback-fail-on-missing key.test-format.readable-metadata properties.bootstrap.servers property-version scan.bounded.mode scan.bounded.specific-offsets scan.bounded.timestamp-millis scan.parallelism scan.watermark.alignment.group scan.watermark.alignment.max-drift scan.watermark.alignment.update-interval scan.watermark.emit.strategy scan.watermark.idle-timeout sink.buffer-flush.interval sink.buffer-flush.max-rows sink.delivery-guarantee sink.parallelism sink.transaction-naming-strategy sink.transactional-id-prefix topic topic-pattern value.fields-include value.format value.test-format.changelog-mode value.test-format.delimiter value.test-format.deprecated-delimiter (deprecated) value.test-format.fail-on-missing value.test-format.fallback-fail-on-missing value.test-format.readable-metadata ``` -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
