Re: Getting an exception while stopping Flink with savepoints on Kubernetes+Minio

Hi, I attached the log files for Jobmanager and Taskmanager: jobmanager_log.asc 6122-f8b99d_log.6122-f8b99d_log

Re: Getting an exception while stopping Flink with savepoints on Kubernetes+Minio

.12.0, Scala: 2.11, Rev:fc00492, Date:2020-12-02T08:49:16+01:00) 2020-12-14 15:04:51,331 INFO org.apache.flink.client.cli.CliFrontend [] - OS current user: folani 2020-12-14 15:04:51,332 INFO org.apache.flink.client.cli.CliFrontend [] - Current H

Getting an exception while stopping Flink with savepoints on Kubernetes+Minio

I'm deploying a standalone Flink cluster on top of Kubernetes and using MinIO as a S3 backend. I mainly follow the instructions in flink's website. I use the following command to run my job in Flink: $flink run -d -m : -j job.jar I also have added to flink-configmap.yaml the followings: s

The best way to get processing time of each operator?

I'm going to work on effect of parallelism for different operators on heterogeneous machines. I need to know the processing time of each operator instance as well as overall processing time of all instances of each specific operator. I think there are different ways for this purpose. However, what