Hi Maciek,

thanks for testing the RC! You are absolutely right. This is a bug. I will create an issue for it.

Thanks again,
Timo


On 31.08.21 16:33, Maciek Próchniak wrote:
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