Nikola Stanisavljevic

You will need to change `kubernetes.cluster-id` config every time you want to deploy a flink app (increment it or take current timestamp) on any FlinkApplication config change. That way when...

This is config option for zookeeper only, and not for kuberenetes ha. We did this in our fork to enable it and to make sure its different every time we...

Any update to this? We experienced problem that @syhily described here https://github.com/streamnative/pulsar-flink/issues/170. After some networking issues after upgrading k8s cluster we started getting `java.lang.OutOfMemoryError: Direct buffer memory` We are using...

I see that upload schema call in releases after 1.13.1.4 is removed https://github.com/streamnative/pulsar-flink/blob/release-1.13.1.4/pulsar-flink-connector/src/main/java/org/apache/flink/streaming/connectors/pulsar/FlinkPulsarSinkBase.java#L267 When will the stable version of 1.13.1.5 is going to be released? At the moment there are...

How to workaround this? Its fixed in latest snapshot, but not in stable release https://issues.apache.org/jira/browse/FLINK-28506