From a01082a5cdee6e4924eb7a11b5f28447687af05e Mon Sep 17 00:00:00 2001 From: Siegfried Weber Date: Fri, 16 Oct 2026 17:53:46 +0200 Subject: [PATCH] test: Adapt the integration tests to Vector 0.58.0 --- CHANGELOG.md | 8 ++--- .../trino-vector-aggregator-values.yaml.j2 | 4 ++- tests/templates/kuttl/smoke/14-assert.yaml.j2 | 30 ++++++++++++++----- 3 files changed, 29 insertions(+), 13 deletions(-) diff --git a/CHANGELOG.md b/CHANGELOG.md index f8aba7303..61976f390 100644 --- a/CHANGELOG.md +++ b/CHANGELOG.md @@ -20,7 +20,7 @@ All notable changes to this project will be documented in this file. always defaulting to `Always` ([#944]). - Internal operator refactoring: introduce a build() step in the reconciler that assembles all relevant Kubernetes resources before anything is applied ([#909]). -- Bump `stackable-operator` to 0.118.0 ([#918], [#932], [#944]). +- Bump `stackable-operator` to 0.121.0 ([#918], [#932], [#944], [#949], [#957]). - The RBAC ServiceAccount and RoleBinding are now built with the operator-rs `v2::rbac` functions and carry the full set of recommended labels ([#913]). - BREAKING: The `coordinators` and `workers` roles are now required by the CRD. @@ -43,12 +43,11 @@ All notable changes to this project will be documented in this file. - Internal operator refactoring: the validated cluster carries each role's configuration in its own typed fields instead of maps keyed by role, and the coordinator's role config is no longer converted to the worker's shape and its listener class recovered afterwards ([#945]). -- Bump stackable-operator to 0.119.0 ([#949]). - test: Bump vector-aggregator to 0.58.0 ([#953]). - test: Update OPA to 1.20.2 in integration tests ([#958]). -- Bump `stackable-operator` to 0.121.0 and replace the unmaintained `serde_yaml` with `yaml_serde` ([#957]). +- Replace the unmaintained `serde_yaml` with `yaml_serde` ([#957]). - All pods now set `securityContext.seccompProfile.type` to `RuntimeDefault` ([#957]). -- Support Vector 0.58.0 ([#953], [#959]). +- Support Vector 0.58.0 ([#953], [#959], [#960]). ### Fixed @@ -87,6 +86,7 @@ All notable changes to this project will be documented in this file. [#957]: https://github.com/stackabletech/trino-operator/pull/957 [#958]: https://github.com/stackabletech/trino-operator/pull/958 [#959]: https://github.com/stackabletech/trino-operator/pull/959 +[#960]: https://github.com/stackabletech/trino-operator/pull/960 ## [26.7.0] - 2026-07-21 diff --git a/tests/templates/kuttl/logging/trino-vector-aggregator-values.yaml.j2 b/tests/templates/kuttl/logging/trino-vector-aggregator-values.yaml.j2 index 760223bb7..b3a248945 100644 --- a/tests/templates/kuttl/logging/trino-vector-aggregator-values.yaml.j2 +++ b/tests/templates/kuttl/logging/trino-vector-aggregator-values.yaml.j2 @@ -124,7 +124,9 @@ customConfig: aggregator: inputs: [vector] type: vector - address: {{ lookup('env', 'VECTOR_AGGREGATOR') }} + routing: + endpoints: + - {{ lookup('env', 'VECTOR_AGGREGATOR') }} buffer: # Avoid back pressure from VECTOR_AGGREGATOR. The test should # not fail if the aggregator is not available. diff --git a/tests/templates/kuttl/smoke/14-assert.yaml.j2 b/tests/templates/kuttl/smoke/14-assert.yaml.j2 index e42297ec5..fa47ddbad 100644 --- a/tests/templates/kuttl/smoke/14-assert.yaml.j2 +++ b/tests/templates/kuttl/smoke/14-assert.yaml.j2 @@ -175,7 +175,7 @@ commands: timestamp_string, err = string(event.timestamp) if err == null { - parsed_timestamp, err = parse_timestamp(timestamp_string, "%Y-%m-%dT%H:%M:%S.%fZ") + parsed_timestamp, err = parse_timestamp(timestamp_string, "%Y-%m-%dT%H:%M:%S.%fZ", timezone: "Etc/UTC") if err == null { .timestamp = parsed_timestamp } else { @@ -212,7 +212,9 @@ commands: # Extends the processed files with the fields "container" and "file" extended_logs_files: inputs: - - processed_files_* + - processed_files_stdout + - processed_files_stderr + - processed_files_airlift type: remap source: | del(.source_type) @@ -250,7 +252,8 @@ commands: # Add the fields "namespace", "cluster", "role" and "roleGroup" to all logs extended_logs: inputs: - - extended_logs_* + - extended_logs_files + - extended_logs_vector type: remap source: | .namespace = "${NAMESPACE}" @@ -264,7 +267,11 @@ commands: inputs: - extended_logs type: vector - address: ${VECTOR_AGGREGATOR_ADDRESS} + routing: + endpoints: + - ${VECTOR_AGGREGATOR_ADDRESS} + compression: zstd + keepalive: {} {% endif %} YAMLEOF ) @@ -428,7 +435,7 @@ commands: timestamp_string, err = string(event.timestamp) if err == null { - parsed_timestamp, err = parse_timestamp(timestamp_string, "%Y-%m-%dT%H:%M:%S.%fZ") + parsed_timestamp, err = parse_timestamp(timestamp_string, "%Y-%m-%dT%H:%M:%S.%fZ", timezone: "Etc/UTC") if err == null { .timestamp = parsed_timestamp } else { @@ -465,7 +472,9 @@ commands: # Extends the processed files with the fields "container" and "file" extended_logs_files: inputs: - - processed_files_* + - processed_files_stdout + - processed_files_stderr + - processed_files_airlift type: remap source: | del(.source_type) @@ -503,7 +512,8 @@ commands: # Add the fields "namespace", "cluster", "role" and "roleGroup" to all logs extended_logs: inputs: - - extended_logs_* + - extended_logs_files + - extended_logs_vector type: remap source: | .namespace = "${NAMESPACE}" @@ -517,7 +527,11 @@ commands: inputs: - extended_logs type: vector - address: ${VECTOR_AGGREGATOR_ADDRESS} + routing: + endpoints: + - ${VECTOR_AGGREGATOR_ADDRESS} + compression: zstd + keepalive: {} {% endif %} YAMLEOF )