RE: Kubernetes Job Cluster - Checkpointing with Parallelism > 1

2018-11-07 Thread Thad Truman
ct: Kubernetes Job Cluster - Checkpointing with Parallelism > 1 Hi all, We are trying to configure checkpointing (RocksDb) for flink job clusters in k8s. As described here<https://github.com/apache/flink/tree/release-1.6/flink-container/kubernetes> we have a par

Kubernetes Job Cluster - Checkpointing with Parallelism > 1

2018-11-06 Thread Thad Truman
Hi all, We are trying to configure checkpointing (RocksDb) for flink job clusters in k8s. As described here we have a parallelism value that is used as the -Dparallelism.default arg in the job manager