From dbcf60f370e93ab490cf82e677387a07ea743cda Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E8=91=A3=E5=8F=AF=E4=BC=A6?= Date: Sat, 11 Sep 2021 15:45:49 +0800 Subject: [PATCH] [MINOR] fix typo (#3640) --- .../hudi/table/action/commit/JavaUpsertPartitioner.java | 6 +++--- .../apache/hudi/table/action/commit/UpsertPartitioner.java | 6 +++--- 2 files changed, 6 insertions(+), 6 deletions(-) diff --git a/hudi-client/hudi-java-client/src/main/java/org/apache/hudi/table/action/commit/JavaUpsertPartitioner.java b/hudi-client/hudi-java-client/src/main/java/org/apache/hudi/table/action/commit/JavaUpsertPartitioner.java index 6b5cb2997..33f59f440 100644 --- a/hudi-client/hudi-java-client/src/main/java/org/apache/hudi/table/action/commit/JavaUpsertPartitioner.java +++ b/hudi-client/hudi-java-client/src/main/java/org/apache/hudi/table/action/commit/JavaUpsertPartitioner.java @@ -189,13 +189,13 @@ public class JavaUpsertPartitioner> implements // Go over all such buckets, and assign weights as per amount of incoming inserts. List insertBuckets = new ArrayList<>(); - double curentCumulativeWeight = 0; + double currentCumulativeWeight = 0; for (int i = 0; i < bucketNumbers.size(); i++) { InsertBucket bkt = new InsertBucket(); bkt.bucketNumber = bucketNumbers.get(i); bkt.weight = (1.0 * recordsPerBucket.get(i)) / pStat.getNumInserts(); - curentCumulativeWeight += bkt.weight; - insertBuckets.add(new InsertBucketCumulativeWeightPair(bkt, curentCumulativeWeight)); + currentCumulativeWeight += bkt.weight; + insertBuckets.add(new InsertBucketCumulativeWeightPair(bkt, currentCumulativeWeight)); } LOG.info("Total insert buckets for partition path " + partitionPath + " => " + insertBuckets); partitionPathToInsertBucketInfos.put(partitionPath, insertBuckets); diff --git a/hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/table/action/commit/UpsertPartitioner.java b/hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/table/action/commit/UpsertPartitioner.java index 3c0a51155..35a8bddf9 100644 --- a/hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/table/action/commit/UpsertPartitioner.java +++ b/hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/table/action/commit/UpsertPartitioner.java @@ -232,13 +232,13 @@ public class UpsertPartitioner> extends Partiti // Go over all such buckets, and assign weights as per amount of incoming inserts. List insertBuckets = new ArrayList<>(); - double curentCumulativeWeight = 0; + double currentCumulativeWeight = 0; for (int i = 0; i < bucketNumbers.size(); i++) { InsertBucket bkt = new InsertBucket(); bkt.bucketNumber = bucketNumbers.get(i); bkt.weight = (1.0 * recordsPerBucket.get(i)) / pStat.getNumInserts(); - curentCumulativeWeight += bkt.weight; - insertBuckets.add(new InsertBucketCumulativeWeightPair(bkt, curentCumulativeWeight)); + currentCumulativeWeight += bkt.weight; + insertBuckets.add(new InsertBucketCumulativeWeightPair(bkt, currentCumulativeWeight)); } LOG.info("Total insert buckets for partition path " + partitionPath + " => " + insertBuckets); partitionPathToInsertBucketInfos.put(partitionPath, insertBuckets);