test: Adapt the integration tests to Vector 0.58.0

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
 

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.

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
       )