From e8321e58db48345cabcaffde63599a5c96ec45a7 Mon Sep 17 00:00:00 2001 From: Nick Larsen Date: Thu, 28 May 2026 14:54:52 +0200 Subject: [PATCH 1/3] test: Bump vector-aggregator to 0.55.0 --- .../kuttl/logging/01-install-hdfs-vector-aggregator.yaml | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/tests/templates/kuttl/logging/01-install-hdfs-vector-aggregator.yaml b/tests/templates/kuttl/logging/01-install-hdfs-vector-aggregator.yaml index 2ef97f83..75a258ed 100644 --- a/tests/templates/kuttl/logging/01-install-hdfs-vector-aggregator.yaml +++ b/tests/templates/kuttl/logging/01-install-hdfs-vector-aggregator.yaml @@ -5,7 +5,7 @@ commands: - script: >- helm install hdfs-vector-aggregator vector --namespace $NAMESPACE - --version 0.49.0 + --version 0.52.0 `# app version 0.55.0` --repo https://helm.vector.dev --values hdfs-vector-aggregator-values.yaml --- From 40b49b4d4c8407d5a68e11786b98229f22f5b5ca Mon Sep 17 00:00:00 2001 From: Nick Larsen Date: Thu, 28 May 2026 15:49:39 +0200 Subject: [PATCH 2/3] test: replace /graphql call with gRPC call --- .../kuttl/logging/test_log_aggregation.py | 51 +++++++++---------- 1 file changed, 23 insertions(+), 28 deletions(-) diff --git a/tests/templates/kuttl/logging/test_log_aggregation.py b/tests/templates/kuttl/logging/test_log_aggregation.py index 845b3814..74ad1023 100755 --- a/tests/templates/kuttl/logging/test_log_aggregation.py +++ b/tests/templates/kuttl/logging/test_log_aggregation.py @@ -1,45 +1,40 @@ -#!/usr/bin/env python3 -import requests +import json +import subprocess def check_sent_events(): - response = requests.post( - "http://hdfs-vector-aggregator:8686/graphql", - json={ - "query": """ - { - transforms(first:100) { - nodes { - componentId - metrics { - sentEventsTotal { - sentEventsTotal - } - } - } - } - } - """ - }, + response = subprocess.run( + [ + "grpcurl", + "-plaintext", + "-d", + '{"limit": 100}', + "hdfs-vector-aggregator:8686", + "vector.observability.v1.ObservabilityService/GetComponents", + ], + capture_output=True, + text=True, + check=True, # Raise a CalledProcessError if non-zero return + timeout=20, # seconds ) + result = json.loads(response.stdout) + components = result.get("components", []) + transforms = [ + c for c in components if c.get("componentType") == "COMPONENT_TYPE_TRANSFORM" + ] - assert response.status_code == 200, ( - "Cannot access the API of the vector aggregator." - ) - - result = response.json() + assert len(transforms) > 0, "No transform components found" - transforms = result["data"]["transforms"]["nodes"] for transform in transforms: sentEvents = transform["metrics"]["sentEventsTotal"] componentId = transform["componentId"] if componentId == "filteredInvalidEvents": - assert sentEvents is None or sentEvents["sentEventsTotal"] == 0, ( + assert sentEvents is None or int(sentEvents) == 0, ( "Invalid log events were sent." ) else: - assert sentEvents is not None and sentEvents["sentEventsTotal"] > 0, ( + assert sentEvents is not None and int(sentEvents) > 0, ( f'No events were sent in "{componentId}".' ) From 15943ef241fd2df6cd2c40445820fb6c8495f60c Mon Sep 17 00:00:00 2001 From: Nick Larsen Date: Thu, 28 May 2026 15:49:55 +0200 Subject: [PATCH 3/3] chore: Update changelog --- CHANGELOG.md | 2 ++ 1 file changed, 2 insertions(+) diff --git a/CHANGELOG.md b/CHANGELOG.md index 5d473cea..7c97e55e 100644 --- a/CHANGELOG.md +++ b/CHANGELOG.md @@ -17,11 +17,13 @@ All notable changes to this project will be documented in this file. Previously, arbitrary file names were silently accepted and ignored ([#777]). - Bump `stackable-operator` to 0.111.1 ([#777], [#778]). - Internal operator refactoring: introduce dereference() and validate() steps in the reconciler ([#783]). +- test: Bump vector-aggregator to 0.55.0, replace /graphql call with gRPC call ([#787]). [#770]: https://github.com/stackabletech/hdfs-operator/pull/770 [#777]: https://github.com/stackabletech/hdfs-operator/pull/777 [#778]: https://github.com/stackabletech/hdfs-operator/pull/778 [#783]: https://github.com/stackabletech/hdfs-operator/pull/783 +[#787]: https://github.com/stackabletech/hdfs-operator/pull/787 ## [26.3.0] - 2026-03-16