From 0d1afabbc6859a356a974c2ef1bd867987a75dcb Mon Sep 17 00:00:00 2001 From: forwardxu Date: Fri, 6 Dec 2024 10:23:38 +0800 Subject: [PATCH] [fix]Fix round-robin strategy name typo --- ...binBucketAssigner.java => RoundRobinBucketAssigner.java} | 6 +++--- .../java/com/alibaba/fluss/client/write/WriterClient.java | 2 +- 2 files changed, 4 insertions(+), 4 deletions(-) rename fluss-client/src/main/java/com/alibaba/fluss/client/write/{RoundRabinBucketAssigner.java => RoundRobinBucketAssigner.java} (92%) diff --git a/fluss-client/src/main/java/com/alibaba/fluss/client/write/RoundRabinBucketAssigner.java b/fluss-client/src/main/java/com/alibaba/fluss/client/write/RoundRobinBucketAssigner.java similarity index 92% rename from fluss-client/src/main/java/com/alibaba/fluss/client/write/RoundRabinBucketAssigner.java rename to fluss-client/src/main/java/com/alibaba/fluss/client/write/RoundRobinBucketAssigner.java index 4ef0d6e9c3..d299a52287 100644 --- a/fluss-client/src/main/java/com/alibaba/fluss/client/write/RoundRabinBucketAssigner.java +++ b/fluss-client/src/main/java/com/alibaba/fluss/client/write/RoundRobinBucketAssigner.java @@ -28,13 +28,13 @@ import java.util.Random; import java.util.concurrent.atomic.AtomicInteger; -/** The bucket assigner use round-rabin strategy. */ +/** The bucket assigner use round-robin strategy. */ @Internal -public class RoundRabinBucketAssigner implements BucketAssigner { +public class RoundRobinBucketAssigner implements BucketAssigner { private final PhysicalTablePath physicalTablePath; private final AtomicInteger counter = new AtomicInteger(new Random().nextInt()); - public RoundRabinBucketAssigner(PhysicalTablePath physicalTablePath) { + public RoundRobinBucketAssigner(PhysicalTablePath physicalTablePath) { this.physicalTablePath = physicalTablePath; } diff --git a/fluss-client/src/main/java/com/alibaba/fluss/client/write/WriterClient.java b/fluss-client/src/main/java/com/alibaba/fluss/client/write/WriterClient.java index 949d25b333..086dcbdcb4 100644 --- a/fluss-client/src/main/java/com/alibaba/fluss/client/write/WriterClient.java +++ b/fluss-client/src/main/java/com/alibaba/fluss/client/write/WriterClient.java @@ -333,7 +333,7 @@ private BucketAssigner createBucketAssigner( ConfigOptions.NoKeyAssigner noKeyAssigner = conf.get(ConfigOptions.CLIENT_WRITER_BUCKET_NO_KEY_ASSIGNER); if (noKeyAssigner == ROUND_ROBIN) { - return new RoundRabinBucketAssigner(physicalTablePath); + return new RoundRobinBucketAssigner(physicalTablePath); } else if (noKeyAssigner == STICKY) { return new StickyBucketAssigner(physicalTablePath); } else {