fix: correct node health change activity logging

silenceqi · silenceqi · commit 25042461a9ea · 2025-02-20T16:32:49.000+08:00
diff --git a/plugin/elastic/metadata.go b/plugin/elastic/metadata.go
@@ -132,7 +132,7 @@ func (processor *MetadataProcessor) HandleUnknownNodeStatus(ev []byte) error {
 	}
 	esClient := elastic.GetClient(processor.config.Elasticsearch)
 	queryDslTpl := `{"script": {
-    "source": "ctx._source.metadata.labels.status='unavailable'",
+    "source": "ctx._source.metadata.labels.status='unknown'",
     "lang": "painless"
   },
   "query": {

Original file line number	Diff line number	Diff line change
`@@ -132,7 +132,7 @@ func (processor *MetadataProcessor) HandleUnknownNodeStatus(ev []byte) error {`
`132`	`132`	`}`
`133`	`133`	`esClient := elastic.GetClient(processor.config.Elasticsearch)`
`134`	`134`	queryDslTpl := `{"script": {
`135`		`- "source": "ctx._source.metadata.labels.status='unavailable'",`
	`135`	`+ "source": "ctx._source.metadata.labels.status='unknown'",`
`136`	`136`	`"lang": "painless"`
`137`	`137`	`},`
`138`	`138`	`"query": {`