From e56dfd6c45a9b35f710b9e8ae4ae301d44f364af Mon Sep 17 00:00:00 2001 From: Keith Massey Date: Fri, 20 Jun 2025 15:23:53 -0500 Subject: [PATCH 1/3] Using the STREAMS_LOGS_SUPPORT_8_19 transport version --- .../elasticsearch/cluster/metadata/StreamsMetadata.java | 8 +++++++- 1 file changed, 7 insertions(+), 1 deletion(-) diff --git a/server/src/main/java/org/elasticsearch/cluster/metadata/StreamsMetadata.java b/server/src/main/java/org/elasticsearch/cluster/metadata/StreamsMetadata.java index 71dd9eeaff24f..0fdd83cb633c5 100644 --- a/server/src/main/java/org/elasticsearch/cluster/metadata/StreamsMetadata.java +++ b/server/src/main/java/org/elasticsearch/cluster/metadata/StreamsMetadata.java @@ -59,7 +59,13 @@ public String getWriteableName() { @Override public TransportVersion getMinimalSupportedVersion() { - return TransportVersions.STREAMS_LOGS_SUPPORT; + throw new IllegalStateException("not used"); + } + + @Override + public boolean supportsVersion(TransportVersion version) { + return version.onOrAfter(TransportVersions.STREAMS_LOGS_SUPPORT) + || version.isPatchFrom(TransportVersions.STREAMS_LOGS_SUPPORT_8_19); } public static NamedDiff readDiffFrom(StreamInput in) throws IOException { From daef732203b96a07fe2a612b6fe471d34026e90f Mon Sep 17 00:00:00 2001 From: Keith Massey Date: Fri, 20 Jun 2025 16:04:17 -0500 Subject: [PATCH 2/3] Update StreamsMetadata.java Returning null from getMinimalSupportedVersion --- .../org/elasticsearch/cluster/metadata/StreamsMetadata.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/server/src/main/java/org/elasticsearch/cluster/metadata/StreamsMetadata.java b/server/src/main/java/org/elasticsearch/cluster/metadata/StreamsMetadata.java index 0fdd83cb633c5..aab5cfdd0463c 100644 --- a/server/src/main/java/org/elasticsearch/cluster/metadata/StreamsMetadata.java +++ b/server/src/main/java/org/elasticsearch/cluster/metadata/StreamsMetadata.java @@ -59,7 +59,7 @@ public String getWriteableName() { @Override public TransportVersion getMinimalSupportedVersion() { - throw new IllegalStateException("not used"); + return null; } @Override From 20d10febad13391967d3b3fc9b2e4f34f510a7f7 Mon Sep 17 00:00:00 2001 From: Luke Whiting Date: Mon, 23 Jun 2025 11:33:16 +0100 Subject: [PATCH 3/3] Return minimal supported version as 8.19 for metadata object to fix test fail --- .../org/elasticsearch/cluster/metadata/StreamsMetadata.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/server/src/main/java/org/elasticsearch/cluster/metadata/StreamsMetadata.java b/server/src/main/java/org/elasticsearch/cluster/metadata/StreamsMetadata.java index aab5cfdd0463c..99758350559d3 100644 --- a/server/src/main/java/org/elasticsearch/cluster/metadata/StreamsMetadata.java +++ b/server/src/main/java/org/elasticsearch/cluster/metadata/StreamsMetadata.java @@ -59,7 +59,7 @@ public String getWriteableName() { @Override public TransportVersion getMinimalSupportedVersion() { - return null; + return TransportVersions.STREAMS_LOGS_SUPPORT_8_19; } @Override