Re: configMap value error when using flink-operator?

2022-10-26 Thread Gyula Fóra
Max sense, I will fix this! Gyula On Thu, Oct 27, 2022 at 4:09 AM Biao Geng wrote: > +1 to Yang's suggestion. > > Yang Wang 于2022年10月26日周三 20:00写道: > >> Maybe we could change the values of *taskmanager.numberOfTaskSlots* and >> *parallelism.default >> *in flink-conf.yaml of Kubernetes operato

Re: configMap value error when using flink-operator?

2022-10-26 Thread Biao Geng
+1 to Yang's suggestion. Yang Wang 于2022年10月26日周三 20:00写道: > Maybe we could change the values of *taskmanager.numberOfTaskSlots* and > *parallelism.default > *in flink-conf.yaml of Kubernetes operator to 1, which are aligned with > the default values in Flink codebase. > > > Best, > Yang > > Gy

Re: configMap value error when using flink-operator?

2022-10-26 Thread Yang Wang
Maybe we could change the values of *taskmanager.numberOfTaskSlots* and *parallelism.default *in flink-conf.yaml of Kubernetes operator to 1, which are aligned with the default values in Flink codebase. Best, Yang Gyula Fóra 于2022年10月26日周三 15:17写道: > Hi! > > I agree that this might be confusin

Re: configMap value error when using flink-operator?

2022-10-26 Thread Gyula Fóra
Hi! I agree that this might be confusing but let me explain what happened. In the operator you can define default flink configuration. Currently it is https://github.com/apache/flink-kubernetes-operator/blob/main/helm/flink-kubernetes-operator/conf/flink-conf.yaml It contains numberOfTaskSlots=2.

configMap value error when using flink-operator?

2022-10-25 Thread Liting Liu (litiliu)
hi:    I'm trying to deploy a flink job with flink-operaotor. The flink-operator's version is 1.2.0. And the yaml i use is here: apiVersion: flink.apache.org/v1beta1 kind: FlinkDeployment metadata: name: basic-example spec: image: flink:1.15 flinkVersion: v1_15 flinkConfiguration: