Native kubernetes integration for standalone job clusters.

2020-06-01 Thread Akshay Iyangar
Hi So we actually run Flink in Kubernetes as a standalone Flink job for each Flink pipeline currently. We wanted to take advantage of Flink HA using K8 but looks like it only supports Flink session clusters currently for version 1.10. Any ideas when will it have support for standalone job cl

** Help need w.r.t parallelism settings in flink **

2019-09-26 Thread Akshay Iyangar
both? 1. Because, Currently I have the parallelism at 8 and maxparallelism at 32 but the UI only shows me that it is using parallelism of 8. It would be great if someone helps me understand the exact behavior of these parameters. Thanks Akshay Iyangar