You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hudi.apache.org by le...@apache.org on 2021/09/11 07:46:01 UTC
[hudi] branch master updated: [MINOR] fix typo (#3640)
This is an automated email from the ASF dual-hosted git repository.
leesf pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/hudi.git
The following commit(s) were added to refs/heads/master by this push:
new dbcf60f [MINOR] fix typo (#3640)
dbcf60f is described below
commit dbcf60f370e93ab490cf82e677387a07ea743cda
Author: 董可伦 <do...@inspur.com>
AuthorDate: Sat Sep 11 15:45:49 2021 +0800
[MINOR] fix typo (#3640)
---
.../org/apache/hudi/table/action/commit/JavaUpsertPartitioner.java | 6 +++---
.../java/org/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 6b5cb29..33f59f4 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<T extends HoodieRecordPayload<T>> implements
// Go over all such buckets, and assign weights as per amount of incoming inserts.
List<InsertBucketCumulativeWeightPair> 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 3c0a511..35a8bdd 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<T extends HoodieRecordPayload<T>> extends Partiti
// Go over all such buckets, and assign weights as per amount of incoming inserts.
List<InsertBucketCumulativeWeightPair> 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);