This is an automated email from the ASF dual-hosted git repository. chufenggao pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/dolphinscheduler-operator.git
commit 1214f2e790ae0f7260bae9884bdb8051ebcad53c Author: caishunfeng <[email protected]> AuthorDate: Tue Sep 20 10:27:00 2022 +0800 update README and add log --- README.md | 20 ++++++++++++++++++++ controllers/dsworker_controller.go | 2 ++ 2 files changed, 22 insertions(+) diff --git a/README.md b/README.md index f673d3c..c03e559 100644 --- a/README.md +++ b/README.md @@ -65,8 +65,16 @@ kubectl apply -f config/ds/zookeeper If you have pv and pvc, you can config it in `config/sameples`. +<<<<<<< Updated upstream Or you can create it with `config/ds/ds-pv.yaml` and `config/configmap/ds-pvc.yaml`. Notice to replace the `hostPath.path` in `ds-pv.yaml`. +======= +<<<<<<< Updated upstream +======= +Or you can create it with `config/ds/ds-pv.yaml` and `config/ds/ds-pvc.yaml`. +Notice to replace the `hostPath.path` in `ds-pv.yaml`. +>>>>>>> Stashed changes +>>>>>>> Stashed changes And you can mount the lib in dolphinscheduler `/opt/soft` in config/samples/ds_v1alpha1_dsworker.yaml with paramter named lib_pvc_name @@ -104,8 +112,20 @@ make build && make manifests && make install && make deploy * Deploy the sample +<<<<<<< Updated upstream ```shell cd config/samples kubectl apply -f ds_v1alpha1_dsalert.yaml kubectl apply -f ds_v1alpha1_api.yaml -f ds_v1alpha1_dsmaster.yaml -f ds_v1alpha1_dsworker.yaml ``` +======= +<<<<<<< Updated upstream +  +======= +```shell +cd config/samples +kubectl apply -f ds_v1alpha1_dsalert.yaml +kubectl apply -f ds_v1alpha1_dsapi.yaml -f ds_v1alpha1_dsmaster.yaml -f ds_v1alpha1_dsworker.yaml +``` +>>>>>>> Stashed changes +>>>>>>> Stashed changes diff --git a/controllers/dsworker_controller.go b/controllers/dsworker_controller.go index 7adf2dc..d0d1a50 100644 --- a/controllers/dsworker_controller.go +++ b/controllers/dsworker_controller.go @@ -207,6 +207,8 @@ func (r *DSWorkerReconciler) ensureScaled(ctx context.Context, cluster *dsv1alph return true, err } + workerLogger.Info("before scale", "podMemberSet", len(ms), "replicas", cluster.Spec.Replicas) + // Scale up if len(ms) < cluster.Spec.Replicas { err = r.createMember(ctx, cluster)
