Skip to content

Commit

Permalink
update README and add log
Browse files Browse the repository at this point in the history
  • Loading branch information
caishunfeng committed Sep 20, 2022
1 parent c124cec commit 1214f2e
Show file tree
Hide file tree
Showing 2 changed files with 22 additions and 0 deletions.
20 changes: 20 additions & 0 deletions README.md
Original file line number Diff line number Diff line change
Expand Up @@ -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

Expand Down Expand Up @@ -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
![image](https://user-images.githubusercontent.com/7134124/171322789-86adfaac-57ad-4e8e-b092-8704b84d20c3.png)
=======
```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
2 changes: 2 additions & 0 deletions controllers/dsworker_controller.go
Original file line number Diff line number Diff line change
Expand Up @@ -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)
Expand Down

0 comments on commit 1214f2e

Please sign in to comment.