Nikola Stanisavljevic
Nikola Stanisavljevic
**Flink pulsar source upgrade from 1.13.1.4 to 1.13.6.2 fails** When upgrading flink pipeline that was using 1.13.1.4 pulsar flink connector, more specifically `org.apache.flink.streaming.connectors.pulsar.FlinkPulsarSource` to 1.13.6.2 pulsar flink connector, upgrade fails...
What is the relation of this project to apache pulsar connector? https://github.com/apache/flink/tree/master/flink-connectors/flink-connector-pulsar Codebase looks quite different. Which one should we use?
We are running a flink sink on topic that it does not have any pulsar schema. Basically we are publishing just json strings. If we dont add service account as...
Handling Flink 1.10+ configuration properly is not released yet but i see that work has been done here https://github.com/lyft/flinkk8soperator/pull/207 Do you have any timeline when this is going to be...