What could be the reason for failure - Key group is not in KeyGroupRange.

2024-11-24 Thread Sachin Mittal
Hi, I am using apache flink 1.18 and running this locally with rocksdb as state backend. So far my pipeline was working fine and was making few adjustments and then it started failing with some weird exception: 2024-11-24 21:54:27,440 WARN org.apache.flink.runtime.taskmanager.Task [] - Task (1/4)#

Fwd: Flink application with statsd failing transiently

2024-11-24 Thread Shubham Badkur
We are using "com.datadoghq" % "java-dogstatsd-client" % "4.2.0", as SBT dependency for our Flink application. Suddenly during HPA rescaling or any general redeployment we are seeing the following jnr related error from StatsDClientBuilder Flink version: 1.18 DatadogClient: 3.33.0 java.lang.Unsat