search

GoogleCloudPlatform / flink-on-k8s-operator

[DEPRECATED] Kubernetes operator for managing the lifecycle of Apache Flink and Beam applications.
Apache License 2.0
657 stars 265 forks source link

create jobcluster failed #403

Closed jiamo closed 3 years ago

jiamo commented 3 years ago 
kubectl apply -f config/samples/flinkoperator_v1beta1_flinkjobcluster.yaml

got such error

Error from server (updating job is not allowed when spec.job.savepointsDir was not provided): error when applying patch:

after add spec.job.savepointsDir.

  job:
    jarFile: ./examples/streaming/WordCount.jar
    className: org.apache.flink.streaming.examples.wordcount.WordCount
    args: ["--input", "./README.txt"]
    parallelism: 2
    savepointsDir: gs://flink-save

the error don't change.

elanv commented 3 years ago

Did you first create FlinkCluster with spec.job.savepointsDir empty and then update spec.job.savepointsDir? As of now, FlinkCluster spec update is only allowed if spec.job.savepointsDir is initially set.

jiamo commented 3 years ago

I think I don't change spec.job.savepointsDir. It this related https://github.com/GoogleCloudPlatform/flink-on-k8s-operator/pull/392 I rebuild the operator and do it again. It is fine now.