Hello,

we are testing 1.14 RC0 and we discovered that we need to include table-api as dependency when using kafka connector - e.g. due to this change:

https://github.com/apache/flink/blame/master/flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/config/StartupMode.java#L75

(don't know if it's the only place).

The table-api is marked as optional dependency, I understand it's needed when using Kafka with table API, but I guess for pure datastream API jobs it shouldn't be needed? Or is it intended and we should just add table-api as provided dependency?


thanks,

maciek

Reply via email to