This is an automated email from the ASF dual-hosted git repository. abhishekrb pushed a commit to branch peon_server_priorities in repository https://gitbox.apache.org/repos/asf/druid.git
commit 9abee83af1011d682d600afc95250f7e0f66ed58 Author: Abhishek Balaji Radhakrishnan <[email protected]> AuthorDate: Thu Feb 26 17:22:31 2026 -0800 Fix casing and variable name --- .../supervisor/SeekableStreamSupervisor.java | 4 ++-- .../supervisor/SeekableStreamSupervisorIOConfig.java | 2 +- .../SeekableStreamSupervisorIOConfigTest.java | 18 +++++++++--------- 3 files changed, 12 insertions(+), 12 deletions(-) diff --git a/indexing-service/src/main/java/org/apache/druid/indexing/seekablestream/supervisor/SeekableStreamSupervisor.java b/indexing-service/src/main/java/org/apache/druid/indexing/seekablestream/supervisor/SeekableStreamSupervisor.java index e826eda9d92..843f0f1ca18 100644 --- a/indexing-service/src/main/java/org/apache/druid/indexing/seekablestream/supervisor/SeekableStreamSupervisor.java +++ b/indexing-service/src/main/java/org/apache/druid/indexing/seekablestream/supervisor/SeekableStreamSupervisor.java @@ -4300,12 +4300,12 @@ public abstract class SeekableStreamSupervisor<PartitionIdType, SequenceOffsetTy * Computes the remaining unassigned server priorities for the given task group. * * @return the unassigned server priorities, or {@code null} if - * {@link SeekableStreamSupervisorIOConfig#getserverPriorityToReplicas()} is not configured + * {@link SeekableStreamSupervisorIOConfig#getServerPriorityToReplicas()} is not configured */ @Nullable public List<Integer> computeUnassignedServerPriorities(final TaskGroup group, final int replicas) { - final Map<Integer, Integer> serverPriorityToReplicas = ioConfig.getserverPriorityToReplicas(); + final Map<Integer, Integer> serverPriorityToReplicas = ioConfig.getServerPriorityToReplicas(); if (serverPriorityToReplicas == null) { return null; } diff --git a/indexing-service/src/main/java/org/apache/druid/indexing/seekablestream/supervisor/SeekableStreamSupervisorIOConfig.java b/indexing-service/src/main/java/org/apache/druid/indexing/seekablestream/supervisor/SeekableStreamSupervisorIOConfig.java index 4f0b5731171..1eb6b8661f7 100644 --- a/indexing-service/src/main/java/org/apache/druid/indexing/seekablestream/supervisor/SeekableStreamSupervisorIOConfig.java +++ b/indexing-service/src/main/java/org/apache/druid/indexing/seekablestream/supervisor/SeekableStreamSupervisorIOConfig.java @@ -164,7 +164,7 @@ public abstract class SeekableStreamSupervisorIOConfig @Nullable @JsonProperty - public Map<Integer, Integer> getserverPriorityToReplicas() + public Map<Integer, Integer> getServerPriorityToReplicas() { return serverPriorityToReplicas; } diff --git a/indexing-service/src/test/java/org/apache/druid/indexing/seekablestream/supervisor/SeekableStreamSupervisorIOConfigTest.java b/indexing-service/src/test/java/org/apache/druid/indexing/seekablestream/supervisor/SeekableStreamSupervisorIOConfigTest.java index e4eac2f4b4d..6d222b8b755 100644 --- a/indexing-service/src/test/java/org/apache/druid/indexing/seekablestream/supervisor/SeekableStreamSupervisorIOConfigTest.java +++ b/indexing-service/src/test/java/org/apache/druid/indexing/seekablestream/supervisor/SeekableStreamSupervisorIOConfigTest.java @@ -41,7 +41,7 @@ import static org.mockito.Mockito.when; public class SeekableStreamSupervisorIOConfigTest { - private final Map<Integer, Integer> serverPriorityToReplica = Map.of( + private final Map<Integer, Integer> serverPriorityToReplicas = Map.of( 1, 2, 2, 3 ); @@ -90,7 +90,7 @@ public class SeekableStreamSupervisorIOConfigTest Assert.assertNull(config.getStopTaskCount()); Assert.assertEquals(lagAggregator, config.getLagAggregator()); Assert.assertEquals(1, config.getMaxAllowedStops()); - Assert.assertNull(config.getserverPriorityToReplicas()); + Assert.assertNull(config.getServerPriorityToReplicas()); } @Test @@ -380,8 +380,8 @@ public class SeekableStreamSupervisorIOConfigTest @Test public void testReplicasIsSetWhenserverPriorityToReplicas() { - final SeekableStreamSupervisorIOConfig config = makeSeekableStreamSupervisorIOConfig(null, serverPriorityToReplica); - Assert.assertEquals(serverPriorityToReplica, config.getserverPriorityToReplicas()); + final SeekableStreamSupervisorIOConfig config = makeSeekableStreamSupervisorIOConfig(null, serverPriorityToReplicas); + Assert.assertEquals(serverPriorityToReplicas, config.getServerPriorityToReplicas()); Assert.assertEquals(Integer.valueOf(5), config.getReplicas()); } @@ -390,15 +390,15 @@ public class SeekableStreamSupervisorIOConfigTest { final SeekableStreamSupervisorIOConfig config = makeSeekableStreamSupervisorIOConfig(4, null); Assert.assertEquals(Integer.valueOf(4), config.getReplicas()); - Assert.assertNull(config.getserverPriorityToReplicas()); + Assert.assertNull(config.getServerPriorityToReplicas()); } @Test public void testMatchingReplicasAndServerPriority() { - final SeekableStreamSupervisorIOConfig config = makeSeekableStreamSupervisorIOConfig(5, serverPriorityToReplica); + final SeekableStreamSupervisorIOConfig config = makeSeekableStreamSupervisorIOConfig(5, serverPriorityToReplicas); Assert.assertEquals(Integer.valueOf(5), config.getReplicas()); - Assert.assertEquals(serverPriorityToReplica, config.getserverPriorityToReplicas()); + Assert.assertEquals(serverPriorityToReplicas, config.getServerPriorityToReplicas()); } @Test @@ -407,12 +407,12 @@ public class SeekableStreamSupervisorIOConfigTest MatcherAssert.assertThat( Assert.assertThrows( DruidException.class, - () -> makeSeekableStreamSupervisorIOConfig(3, serverPriorityToReplica) + () -> makeSeekableStreamSupervisorIOConfig(3, serverPriorityToReplicas) ), DruidExceptionMatcher.invalidInput().expectMessageIs( StringUtils.format( "Configured replicas[3] != sum of replicas[5] specified in serverPriorityToReplicas[%s].", - serverPriorityToReplica + serverPriorityToReplicas ) ) ); --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
