From ce46c659e3532a72d3dace9e26cadb0068a8279a Mon Sep 17 00:00:00 2001 From: Gabriel Chang <77312579+GabrielCWT@users.noreply.github.com> Date: Tue, 9 Sep 2025 16:25:04 +0800 Subject: [PATCH 01/11] Add version to sys.servers --- .../AbstractAuthConfigurationTest.java | 13 +++-- .../results/auth_test_sys_schema_servers.json | 6 ++- .../sql/calcite/schema/SystemSchema.java | 9 ++-- .../sql/calcite/schema/SystemSchemaTest.java | 53 +++++++++++++------ 4 files changed, 54 insertions(+), 27 deletions(-) diff --git a/integration-tests/src/test/java/org/apache/druid/tests/security/AbstractAuthConfigurationTest.java b/integration-tests/src/test/java/org/apache/druid/tests/security/AbstractAuthConfigurationTest.java index c92ae0676678..53803b098136 100644 --- a/integration-tests/src/test/java/org/apache/druid/tests/security/AbstractAuthConfigurationTest.java +++ b/integration-tests/src/test/java/org/apache/druid/tests/security/AbstractAuthConfigurationTest.java @@ -284,7 +284,7 @@ public void test_systemSchemaAccess_admin() throws Exception verifySystemSchemaServerQuery( adminClient, SYS_SCHEMA_SERVERS_QUERY, - getServersWithoutCurrentSizeAndStartTime(adminServers) + getServersWithoutNonConfigurableFields(adminServers) ); LOG.info("Checking sys.server_segments query as admin..."); @@ -858,7 +858,7 @@ protected void verifySystemSchemaQueryBase( String content = responseHolder.getContent(); List> responseMap = jsonMapper.readValue(content, SYS_SCHEMA_RESULTS_TYPE_REFERENCE); if (isServerQuery) { - responseMap = getServersWithoutCurrentSizeAndStartTime(responseMap); + responseMap = getServersWithoutNonConfigurableFields(responseMap); } Assert.assertEquals(responseMap, expectedResults); } @@ -1005,7 +1005,7 @@ protected void setExpectedSystemSchemaObjects() throws IOException SYS_SCHEMA_RESULTS_TYPE_REFERENCE ); - adminServers = getServersWithoutCurrentSizeAndStartTime( + adminServers = getServersWithoutNonConfigurableFields( jsonMapper.readValue( fillServersTemplate( config, @@ -1025,10 +1025,12 @@ protected void setExpectedSystemSchemaObjects() throws IOException } /** - * curr_size on historicals changes because cluster state is not isolated across different + * curr_size on historicals changes because cluster state is not isolated across + * different * integration tests, zero it out for consistent test results + * version and start_time are not configurable therefore we zero them as well */ - protected static List> getServersWithoutCurrentSizeAndStartTime(List> servers) + protected static List> getServersWithoutNonConfigurableFields(List> servers) { return Lists.transform( servers, @@ -1036,6 +1038,7 @@ protected static List> getServersWithoutCurrentSizeAndStartT Map newServer = new HashMap<>(server); newServer.put("curr_size", 0); newServer.put("start_time", "0"); + newServer.put("version", "0.0.0"); return newServer; } ); diff --git a/integration-tests/src/test/resources/results/auth_test_sys_schema_servers.json b/integration-tests/src/test/resources/results/auth_test_sys_schema_servers.json index 8c4fb14c5206..520fde8ff56e 100644 --- a/integration-tests/src/test/resources/results/auth_test_sys_schema_servers.json +++ b/integration-tests/src/test/resources/results/auth_test_sys_schema_servers.json @@ -9,7 +9,8 @@ "curr_size": 2208932412, "max_size": 5000000000, "is_leader": null, - "start_time": "0" + "start_time": "0", + "version": "0.0.0" }, { "server": "%%BROKER%%:8282", @@ -21,6 +22,7 @@ "curr_size": 0, "max_size": 1000000000, "is_leader": null, - "start_time": "0" + "start_time": "0", + "version": "0.0.0" } ] diff --git a/sql/src/main/java/org/apache/druid/sql/calcite/schema/SystemSchema.java b/sql/src/main/java/org/apache/druid/sql/calcite/schema/SystemSchema.java index 76e6f37ab597..41b9dc1f535b 100644 --- a/sql/src/main/java/org/apache/druid/sql/calcite/schema/SystemSchema.java +++ b/sql/src/main/java/org/apache/druid/sql/calcite/schema/SystemSchema.java @@ -180,6 +180,7 @@ public class SystemSchema extends AbstractSchema .add("max_size", ColumnType.LONG) .add("is_leader", ColumnType.LONG) .add("start_time", ColumnType.STRING) + .add("version", ColumnType.STRING) .build(); static final RowSignature SERVER_SEGMENTS_SIGNATURE = RowSignature @@ -639,7 +640,8 @@ private static Object[] buildRowForNonDataServer(DiscoveryDruidNode discoveryDru UNKNOWN_SIZE, UNKNOWN_SIZE, null, - toStringOrNull(discoveryDruidNode.getStartTime()) + toStringOrNull(discoveryDruidNode.getStartTime()), + node.getVersion() }; } @@ -662,7 +664,8 @@ private static Object[] buildRowForNonDataServerWithLeadership( UNKNOWN_SIZE, UNKNOWN_SIZE, isLeader ? 1L : 0L, - toStringOrNull(discoveryDruidNode.getStartTime()) + toStringOrNull(discoveryDruidNode.getStartTime()), + node.getVersion() }; } @@ -697,7 +700,7 @@ private static Object[] buildRowForDiscoverableDataServer( currentSize, druidServerToUse.getMaxSize(), null, - toStringOrNull(discoveryDruidNode.getStartTime()) + node.getVersion() }; } diff --git a/sql/src/test/java/org/apache/druid/sql/calcite/schema/SystemSchemaTest.java b/sql/src/test/java/org/apache/druid/sql/calcite/schema/SystemSchemaTest.java index 0fc01c1aa09c..84266a2e459e 100644 --- a/sql/src/test/java/org/apache/druid/sql/calcite/schema/SystemSchemaTest.java +++ b/sql/src/test/java/org/apache/druid/sql/calcite/schema/SystemSchemaTest.java @@ -381,6 +381,8 @@ public void setUp(@TempDir File tmpDir) throws Exception private final DateTime startTime = DateTimes.nowUtc(); + private final String version = new DruidNode("s1", "localhost", false, 8081, null, true, false).getVersion(); + private final DiscoveryDruidNode coordinator = new DiscoveryDruidNode( new DruidNode("s1", "localhost", false, 8081, null, true, false), NodeRole.COORDINATOR, @@ -851,7 +853,8 @@ public void testServersTable() throws URISyntaxException 0L, 0L, nonLeader, - startTimeStr + startTimeStr, + version ) ); expectedRows.add( @@ -865,7 +868,8 @@ public void testServersTable() throws URISyntaxException 0L, 1000L, nonLeader, - startTimeStr + startTimeStr, + version ) ); expectedRows.add( @@ -879,7 +883,8 @@ public void testServersTable() throws URISyntaxException 400L, 1000L, nonLeader, - startTimeStr + startTimeStr, + version ) ); expectedRows.add( @@ -893,7 +898,8 @@ public void testServersTable() throws URISyntaxException 0L, 1000L, nonLeader, - startTimeStr + startTimeStr, + version ) ); expectedRows.add( @@ -907,7 +913,8 @@ public void testServersTable() throws URISyntaxException 0L, 1000L, nonLeader, - startTimeStr + startTimeStr, + version ) ); expectedRows.add(createExpectedRow( @@ -920,7 +927,8 @@ public void testServersTable() throws URISyntaxException 0L, 1000L, nonLeader, - startTimeStr + startTimeStr, + version )); expectedRows.add( createExpectedRow( @@ -933,7 +941,8 @@ public void testServersTable() throws URISyntaxException 0L, 0L, 1L, - startTimeStr + startTimeStr, + version ) ); expectedRows.add( @@ -947,7 +956,8 @@ public void testServersTable() throws URISyntaxException 0L, 0L, nonLeader, - startTimeStr + startTimeStr, + version ) ); expectedRows.add( @@ -961,7 +971,8 @@ public void testServersTable() throws URISyntaxException 200L, 1000L, nonLeader, - startTimeStr + startTimeStr, + version ) ); expectedRows.add( @@ -975,7 +986,8 @@ public void testServersTable() throws URISyntaxException 0L, 0L, 1L, - startTimeStr + startTimeStr, + version ) ); expectedRows.add( @@ -989,7 +1001,8 @@ public void testServersTable() throws URISyntaxException 0L, 0L, 0L, - startTimeStr + startTimeStr, + version ) ); expectedRows.add( @@ -1003,7 +1016,8 @@ public void testServersTable() throws URISyntaxException 0L, 0L, 0L, - startTimeStr + startTimeStr, + version ) ); expectedRows.add( @@ -1017,7 +1031,8 @@ public void testServersTable() throws URISyntaxException 0L, 0L, nonLeader, - startTimeStr + startTimeStr, + version ) ); expectedRows.add( @@ -1031,7 +1046,8 @@ public void testServersTable() throws URISyntaxException 0L, 0L, nonLeader, - startTimeStr + startTimeStr, + version ) ); expectedRows.add(createExpectedRow( @@ -1044,7 +1060,8 @@ public void testServersTable() throws URISyntaxException 0L, 1000L, nonLeader, - startTimeStr + startTimeStr, + version )); Assert.assertEquals(expectedRows.size(), rows.size()); for (int i = 0; i < rows.size(); i++) { @@ -1077,7 +1094,8 @@ private Object[] createExpectedRow( @Nullable Long currSize, @Nullable Long maxSize, @Nullable Long isLeader, - String startTime + String startTime, + String version ) { return new Object[]{ @@ -1090,7 +1108,8 @@ private Object[] createExpectedRow( currSize, maxSize, isLeader, - startTime + startTime, + version }; } From 5309c0f908bfae6b834c71c9da93f8840c5c96ca Mon Sep 17 00:00:00 2001 From: Gabriel Chang <77312579+GabrielCWT@users.noreply.github.com> Date: Tue, 9 Sep 2025 16:25:14 +0800 Subject: [PATCH 02/11] Display version in services tab --- docs/querying/sql-metadata-tables.md | 1 + .../__snapshots__/services-view.spec.tsx.snap | 9 +++++++++ .../src/views/services-view/services-view.tsx | 14 +++++++++++++- 3 files changed, 23 insertions(+), 1 deletion(-) diff --git a/docs/querying/sql-metadata-tables.md b/docs/querying/sql-metadata-tables.md index cd2db5cf14c2..597db319b057 100644 --- a/docs/querying/sql-metadata-tables.md +++ b/docs/querying/sql-metadata-tables.md @@ -236,6 +236,7 @@ Servers table lists all discovered servers in the cluster. |max_size|BIGINT|Max size in bytes this server recommends to assign to segments see [druid.server.maxSize](../configuration/index.md#historical-general-configuration). Only valid for HISTORICAL type, for other types it's 0| |is_leader|BIGINT|1 if the server is currently the 'leader' (for services which have the concept of leadership), otherwise 0 if the server is not the leader, or null if the server type does not have the concept of leadership| |start_time|STRING|Timestamp in ISO8601 format when the server was announced in the cluster| +|version|VARCHAR|Version of the server| To retrieve information about all servers, use the query: ```sql diff --git a/web-console/src/views/services-view/__snapshots__/services-view.spec.tsx.snap b/web-console/src/views/services-view/__snapshots__/services-view.spec.tsx.snap index 329a7fd3562a..b21581166968 100644 --- a/web-console/src/views/services-view/__snapshots__/services-view.spec.tsx.snap +++ b/web-console/src/views/services-view/__snapshots__/services-view.spec.tsx.snap @@ -58,6 +58,7 @@ exports[`ServicesView renders data 1`] = ` "Max size", "Usage", "Start time", + "Version", "Detail", ] } @@ -208,6 +209,14 @@ exports[`ServicesView renders data 1`] = ` "show": true, "width": 200, }, + { + "Aggregated": [Function], + "Cell": [Function], + "Header": "Version", + "accessor": "version", + "show": true, + "width": 200, + }, { "Aggregated": [Function], "Cell": [Function], diff --git a/web-console/src/views/services-view/services-view.tsx b/web-console/src/views/services-view/services-view.tsx index ea9c5653e9dc..8aa67f88513b 100644 --- a/web-console/src/views/services-view/services-view.tsx +++ b/web-console/src/views/services-view/services-view.tsx @@ -84,6 +84,7 @@ const TABLE_COLUMNS_BY_MODE: Record '', }, + { + Header: 'Version', + show: visibleColumns.shown('Version'), + accessor: 'version', + width: 200, + Cell: this.renderFilterableCell('version'), + Aggregated: () => '', + }, { Header: 'Detail', show: visibleColumns.shown('Detail'), From 71c314a797db0a65d22647df98951b1c187f9db5 Mon Sep 17 00:00:00 2001 From: Gabriel Chang <77312579+GabrielCWT@users.noreply.github.com> Date: Thu, 18 Sep 2025 17:11:01 +0800 Subject: [PATCH 03/11] Fixing missing version assignment --- web-console/src/views/services-view/services-view.tsx | 1 + 1 file changed, 1 insertion(+) diff --git a/web-console/src/views/services-view/services-view.tsx b/web-console/src/views/services-view/services-view.tsx index 8aa67f88513b..9e897b15b2bf 100644 --- a/web-console/src/views/services-view/services-view.tsx +++ b/web-console/src/views/services-view/services-view.tsx @@ -291,6 +291,7 @@ ORDER BY max_size: s.maxSize, start_time: '1970:01:01T00:00:00Z', is_leader: 0, + version: '' }; }, ); From b47d63bcab88cf5f9955e440a56312b5576ed8ae Mon Sep 17 00:00:00 2001 From: Gabriel Chang <77312579+GabrielCWT@users.noreply.github.com> Date: Thu, 18 Sep 2025 17:56:02 +0800 Subject: [PATCH 04/11] Fix format errors --- web-console/src/views/services-view/services-view.tsx | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/web-console/src/views/services-view/services-view.tsx b/web-console/src/views/services-view/services-view.tsx index 9e897b15b2bf..1ac4e42c712a 100644 --- a/web-console/src/views/services-view/services-view.tsx +++ b/web-console/src/views/services-view/services-view.tsx @@ -291,7 +291,7 @@ ORDER BY max_size: s.maxSize, start_time: '1970:01:01T00:00:00Z', is_leader: 0, - version: '' + version: '', }; }, ); From 34135cceb42e76e56f63a8924d80c00ddd225858 Mon Sep 17 00:00:00 2001 From: Gabriel Chang <77312579+GabrielCWT@users.noreply.github.com> Date: Fri, 19 Sep 2025 10:15:05 +0800 Subject: [PATCH 05/11] Add back removed line --- .../java/org/apache/druid/sql/calcite/schema/SystemSchema.java | 1 + 1 file changed, 1 insertion(+) diff --git a/sql/src/main/java/org/apache/druid/sql/calcite/schema/SystemSchema.java b/sql/src/main/java/org/apache/druid/sql/calcite/schema/SystemSchema.java index 41b9dc1f535b..c33ce7208c74 100644 --- a/sql/src/main/java/org/apache/druid/sql/calcite/schema/SystemSchema.java +++ b/sql/src/main/java/org/apache/druid/sql/calcite/schema/SystemSchema.java @@ -700,6 +700,7 @@ private static Object[] buildRowForDiscoverableDataServer( currentSize, druidServerToUse.getMaxSize(), null, + toStringOrNull(discoveryDruidNode.getStartTime()) node.getVersion() }; } From 46218fc06b876fd3f1865628d9ed770d486fcd2d Mon Sep 17 00:00:00 2001 From: Gabriel Chang <77312579+GabrielCWT@users.noreply.github.com> Date: Fri, 19 Sep 2025 14:33:33 +0800 Subject: [PATCH 06/11] Fix based on comments --- docs/querying/sql-metadata-tables.md | 2 +- .../apache/druid/sql/calcite/schema/SystemSchemaTest.java | 6 +++++- 2 files changed, 6 insertions(+), 2 deletions(-) diff --git a/docs/querying/sql-metadata-tables.md b/docs/querying/sql-metadata-tables.md index 597db319b057..aa1804e29d56 100644 --- a/docs/querying/sql-metadata-tables.md +++ b/docs/querying/sql-metadata-tables.md @@ -236,7 +236,7 @@ Servers table lists all discovered servers in the cluster. |max_size|BIGINT|Max size in bytes this server recommends to assign to segments see [druid.server.maxSize](../configuration/index.md#historical-general-configuration). Only valid for HISTORICAL type, for other types it's 0| |is_leader|BIGINT|1 if the server is currently the 'leader' (for services which have the concept of leadership), otherwise 0 if the server is not the leader, or null if the server type does not have the concept of leadership| |start_time|STRING|Timestamp in ISO8601 format when the server was announced in the cluster| -|version|VARCHAR|Version of the server| +|version|VARCHAR|Druid version running on the server| To retrieve information about all servers, use the query: ```sql diff --git a/sql/src/test/java/org/apache/druid/sql/calcite/schema/SystemSchemaTest.java b/sql/src/test/java/org/apache/druid/sql/calcite/schema/SystemSchemaTest.java index 84266a2e459e..f7260d2ae5d4 100644 --- a/sql/src/test/java/org/apache/druid/sql/calcite/schema/SystemSchemaTest.java +++ b/sql/src/test/java/org/apache/druid/sql/calcite/schema/SystemSchemaTest.java @@ -44,6 +44,7 @@ import org.apache.druid.client.TimelineServerView; import org.apache.druid.client.coordinator.CoordinatorClient; import org.apache.druid.client.coordinator.NoopCoordinatorClient; +import org.apache.druid.common.guava.GuavaUtils; import org.apache.druid.data.input.InputRow; import org.apache.druid.data.input.impl.DimensionsSpec; import org.apache.druid.data.input.impl.StringDimensionSchema; @@ -381,7 +382,10 @@ public void setUp(@TempDir File tmpDir) throws Exception private final DateTime startTime = DateTimes.nowUtc(); - private final String version = new DruidNode("s1", "localhost", false, 8081, null, true, false).getVersion(); + private final String version = GuavaUtils.firstNonNull( + SystemSchemaTest.class.getPackage().getImplementationVersion(), + "unknown" +); private final DiscoveryDruidNode coordinator = new DiscoveryDruidNode( new DruidNode("s1", "localhost", false, 8081, null, true, false), From 1d1beaf702a19ef060bb103b931ff3cd2ed12213 Mon Sep 17 00:00:00 2001 From: Gabriel Chang <77312579+GabrielCWT@users.noreply.github.com> Date: Tue, 23 Sep 2025 11:07:35 +0800 Subject: [PATCH 07/11] Refactor unknown version string to constant --- server/src/main/java/org/apache/druid/server/DruidNode.java | 4 +++- .../org/apache/druid/sql/calcite/schema/SystemSchemaTest.java | 2 +- 2 files changed, 4 insertions(+), 2 deletions(-) diff --git a/server/src/main/java/org/apache/druid/server/DruidNode.java b/server/src/main/java/org/apache/druid/server/DruidNode.java index 225f054c73ef..0e3b3e4b4d02 100644 --- a/server/src/main/java/org/apache/druid/server/DruidNode.java +++ b/server/src/main/java/org/apache/druid/server/DruidNode.java @@ -44,6 +44,8 @@ */ public class DruidNode { + public static final String UNKNOWN_VERSION = "unknown"; + @JsonProperty("service") @NotNull private String serviceName; @@ -86,7 +88,7 @@ public class DruidNode @NotNull private final String version = GuavaUtils.firstNonNull( DruidNode.class.getPackage().getImplementationVersion(), - "unknown" + UNKNOWN_VERSION ); public DruidNode( diff --git a/sql/src/test/java/org/apache/druid/sql/calcite/schema/SystemSchemaTest.java b/sql/src/test/java/org/apache/druid/sql/calcite/schema/SystemSchemaTest.java index f7260d2ae5d4..b6c8f6e1d9e0 100644 --- a/sql/src/test/java/org/apache/druid/sql/calcite/schema/SystemSchemaTest.java +++ b/sql/src/test/java/org/apache/druid/sql/calcite/schema/SystemSchemaTest.java @@ -384,7 +384,7 @@ public void setUp(@TempDir File tmpDir) throws Exception private final String version = GuavaUtils.firstNonNull( SystemSchemaTest.class.getPackage().getImplementationVersion(), - "unknown" + DruidNode.UNKNOWN_VERSION ); private final DiscoveryDruidNode coordinator = new DiscoveryDruidNode( From 95fade1e446947e499ccb8f67dc9b4bb24725fa5 Mon Sep 17 00:00:00 2001 From: Gabriel Chang <77312579+GabrielCWT@users.noreply.github.com> Date: Tue, 23 Sep 2025 11:07:55 +0800 Subject: [PATCH 08/11] Fix missing syntax --- .../java/org/apache/druid/sql/calcite/schema/SystemSchema.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/sql/src/main/java/org/apache/druid/sql/calcite/schema/SystemSchema.java b/sql/src/main/java/org/apache/druid/sql/calcite/schema/SystemSchema.java index c33ce7208c74..932404f21e78 100644 --- a/sql/src/main/java/org/apache/druid/sql/calcite/schema/SystemSchema.java +++ b/sql/src/main/java/org/apache/druid/sql/calcite/schema/SystemSchema.java @@ -700,7 +700,7 @@ private static Object[] buildRowForDiscoverableDataServer( currentSize, druidServerToUse.getMaxSize(), null, - toStringOrNull(discoveryDruidNode.getStartTime()) + toStringOrNull(discoveryDruidNode.getStartTime()), node.getVersion() }; } From aa5c627bebbcd627e34ff49ae50a0b04073d7a46 Mon Sep 17 00:00:00 2001 From: Gabriel Chang <77312579+GabrielCWT@users.noreply.github.com> Date: Tue, 23 Sep 2025 15:25:17 +0800 Subject: [PATCH 09/11] Update tests --- .../apache/druid/sql/calcite/schema/SystemSchemaTest.java | 7 +++---- 1 file changed, 3 insertions(+), 4 deletions(-) diff --git a/sql/src/test/java/org/apache/druid/sql/calcite/schema/SystemSchemaTest.java b/sql/src/test/java/org/apache/druid/sql/calcite/schema/SystemSchemaTest.java index b6c8f6e1d9e0..60df33d9b16f 100644 --- a/sql/src/test/java/org/apache/druid/sql/calcite/schema/SystemSchemaTest.java +++ b/sql/src/test/java/org/apache/druid/sql/calcite/schema/SystemSchemaTest.java @@ -383,9 +383,8 @@ public void setUp(@TempDir File tmpDir) throws Exception private final DateTime startTime = DateTimes.nowUtc(); private final String version = GuavaUtils.firstNonNull( - SystemSchemaTest.class.getPackage().getImplementationVersion(), - DruidNode.UNKNOWN_VERSION -); + SystemSchemaTest.class.getPackage().getImplementationVersion(), + DruidNode.UNKNOWN_VERSION); private final DiscoveryDruidNode coordinator = new DiscoveryDruidNode( new DruidNode("s1", "localhost", false, 8081, null, true, false), @@ -558,7 +557,7 @@ public void testGetTableMap() final SystemSchema.ServersTable serversTable = (SystemSchema.ServersTable) schema.getTableMap().get("servers"); final RelDataType serverRowType = serversTable.getRowType(new JavaTypeFactoryImpl()); final List serverFields = serverRowType.getFieldList(); - Assert.assertEquals(10, serverFields.size()); + Assert.assertEquals(11, serverFields.size()); Assert.assertEquals("server", serverFields.get(0).getName()); Assert.assertEquals(SqlTypeName.VARCHAR, serverFields.get(0).getType().getSqlTypeName()); } From 3e1588ed6645b99f46fa498590cc68e2b0e820be Mon Sep 17 00:00:00 2001 From: Gabriel Chang <77312579+GabrielCWT@users.noreply.github.com> Date: Tue, 23 Sep 2025 18:23:23 +0800 Subject: [PATCH 10/11] Fix format --- .../org/apache/druid/sql/calcite/schema/SystemSchemaTest.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/sql/src/test/java/org/apache/druid/sql/calcite/schema/SystemSchemaTest.java b/sql/src/test/java/org/apache/druid/sql/calcite/schema/SystemSchemaTest.java index 60df33d9b16f..d523d970fccf 100644 --- a/sql/src/test/java/org/apache/druid/sql/calcite/schema/SystemSchemaTest.java +++ b/sql/src/test/java/org/apache/druid/sql/calcite/schema/SystemSchemaTest.java @@ -384,7 +384,8 @@ public void setUp(@TempDir File tmpDir) throws Exception private final String version = GuavaUtils.firstNonNull( SystemSchemaTest.class.getPackage().getImplementationVersion(), - DruidNode.UNKNOWN_VERSION); + DruidNode.UNKNOWN_VERSION + ); private final DiscoveryDruidNode coordinator = new DiscoveryDruidNode( new DruidNode("s1", "localhost", false, 8081, null, true, false), From b95c91a091c4317146e73402988765dbf22fe06f Mon Sep 17 00:00:00 2001 From: Gabriel Chang <77312579+GabrielCWT@users.noreply.github.com> Date: Wed, 24 Sep 2025 15:05:00 +0800 Subject: [PATCH 11/11] Refactor test to use DruidNode.UNKNOWN_VERSION --- server/src/test/java/org/apache/druid/server/DruidNodeTest.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/server/src/test/java/org/apache/druid/server/DruidNodeTest.java b/server/src/test/java/org/apache/druid/server/DruidNodeTest.java index f0fde0117ac9..77edaaad1379 100644 --- a/server/src/test/java/org/apache/druid/server/DruidNodeTest.java +++ b/server/src/test/java/org/apache/druid/server/DruidNodeTest.java @@ -53,7 +53,7 @@ public void testDefaultsAndSanity() // Hosts which report only ipv6 will have getDefaultHost() report something like fe80::6e40:8ff:fe93:9230 // but getHostAndPort() reports [fe80::6e40:8ff:fe93:9230] Assert.assertEquals(HostAndPort.fromString(DruidNode.getDefaultHost()).toString(), node.getHostAndPort()); - Assert.assertEquals("unknown", node.getVersion()); // unknown because not compiled with version + Assert.assertEquals(DruidNode.UNKNOWN_VERSION, node.getVersion()); // unknown because not compiled with version node = new DruidNode(service, "2001:db8:85a3::8a2e:370:7334", false, -1, null, true, false); Assert.assertEquals("2001:db8:85a3::8a2e:370:7334", node.getHost());