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