Re: influxdb metrics reporter - 4k series per job restart

Hi All, Thank you for your replies. What ended up working for me was setting metrics.reporter.influxdb.scope.variables.excludes: job_id;task_attempt_num;tm_id;task_id;operator_id;task_attempt_id On Fri, 1 Jul 2022 at 18:36, Mason Chen wrote: > Hi all, > > If you can wait for Flink 1.16, there

NodePort conflict for multiple HA application-mode standalone Kubernetes deploys in same namespace

I am deploying a high-availability Flink job to Kubernetes in application mode using Flink's standalone k8 deployment https://nightlies.apache.org/flink/flink-docs-release-1.15/docs/deployment/resource-providers/standalone/kubernetes/ All goes well when I deploy a job, but if I want to deploy a sec

Re: Decompressing RMQ streaming messages

Hi Francis - Thanks for the snippet. I tried using the same, however I get an error. Following is the error - java.util.zip.DataFormatException: incorrect header check. I see multiple errors, i beleive for every message i am seeing this stack trace? Any idea as to what could be causing this? T