Could not resolve ResourceManager address in native kubernetes

2021-05-10 Thread Valentin Wallyn
Hi, I'm trying to use Flink on native kubernetes ( https://ci.apache.org/projects/flink/flink-docs-release-1.13/docs/deployment/resource-providers/native_kubernetes/) but I have an error even with the example from the documentation. The job get submitted but stays in "created" status until it tim

FlinkKafkaConsumer using Kafka-GroupID?

2017-05-17 Thread Valentin
re any chance to run 2 different flink (standalone) apps consuming messages from a single kafka-topic only once? This is what I could do by using 2 native Kafka-Consumers within the same consumer-group. Many thanks in advance Valentin