I hereby claim:
- I am barkbay on github.
- I am morello (https://keybase.io/morello) on keybase.
- I have a public key ASBpP_1ULjTovAUK56s_iOT2Vw8qj7l64F6rYoaBWTswsgo
To claim this, I am signing this object:
{ | |
"level": "info", | |
"@timestamp": "2020-01-10T07:16:39.271Z", | |
"logger": "driver", | |
"message": "Cqndidates before sort", | |
"ver": "1.0.0-7da3f193", | |
"candidates": [{ | |
"kind": "Pod", | |
"apiVersion": "v1", | |
"metadata": { |
apiVersion: v1 | |
kind: Namespace | |
metadata: | |
name: elasticsearch-namespace | |
--- | |
apiVersion: elasticsearch.k8s.elastic.co/v1 | |
kind: Elasticsearch | |
metadata: | |
name: es-apm-sample | |
namespace: elasticsearch-namespace |
apiVersion: v1 | |
kind: Namespace | |
metadata: | |
name: elasticsearch-namespace | |
--- | |
apiVersion: elasticsearch.k8s.elastic.co/v1 | |
kind: Elasticsearch | |
metadata: | |
name: es-apm-sample | |
namespace: elasticsearch-namespace |
apiVersion: v1 | |
kind: Namespace | |
metadata: | |
name: elasticsearch-namespace | |
--- | |
apiVersion: v1 | |
kind: Namespace | |
metadata: | |
name: apm-namespace | |
--- |
# This sample sets up a an Elasticsearch cluster along with a Kibana instance | |
# and an APM server, configured to be able to communicate with each other | |
--- | |
apiVersion: v1 | |
kind: Namespace | |
metadata: | |
name: v1alpha1 | |
--- | |
apiVersion: elasticsearch.k8s.elastic.co/v1alpha1 | |
kind: Elasticsearch |
apiVersion: elasticsearch.k8s.elastic.co/v1alpha1 | |
kind: Elasticsearch | |
metadata: | |
name: elasticsearch-sample | |
spec: | |
version: 7.2.0 | |
updateStrategy: | |
changeBudget: | |
maxUnavailable: 1 | |
maxSurge: 1 |
diff --git a/pkg/controller/elasticsearch/driver/downscale.go b/pkg/controller/elasticsearch/driver/downscale.go | |
index cc60511a..9d1b9f5d 100644 | |
--- a/pkg/controller/elasticsearch/driver/downscale.go | |
+++ b/pkg/controller/elasticsearch/driver/downscale.go | |
@@ -31,8 +31,16 @@ func HandleDownscale( | |
) *reconciler.Results { | |
results := &reconciler.Results{} | |
+ // make sure we only downscale nodes we're allowed to | |
+ downscaleState, err := newDownscaleState(downscaleCtx.k8sClient, downscaleCtx.es) |
{ | |
"_shards" : { | |
"total" : 4, | |
"successful" : 4, | |
"failed" : 0 | |
}, | |
"_all" : { | |
"primaries" : { | |
"docs" : { | |
"count" : 41, |
I hereby claim:
To claim this, I am signing this object:
--- | |
apiVersion: v1 | |
kind: Namespace | |
metadata: | |
name: ceph | |
--- | |
apiVersion: v1 | |
kind: ServiceAccount | |
metadata: | |
name: ceph |