Hi,
When running your code in the IDE, everything runs in the same local JVM.
When you run the job on Kubernetes, the situation is very different.
Your code runs in multiple JVM processes distributed in a cluster.
Flink provides a metrics collection system that you should use to collect metrics from the various processes.
Please have a look at the metrics documentation [1].
Best, Fabian
Hi All,
I have some very simple MDC logs in my flink job:
MDC.put("methodName", new Object() {}.getClass().getEnclosingMethod().getName());
MDC.put("className", this.getClass().getSimpleName());
When I run flink job locally, I can see them in the application logs.
But when I run the same job on kubernetes clutter, these don't show up.
Any input here?
With regards
Locked
