This is an automated email from the ASF dual-hosted git repository.

yihua 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 dd1a2f544e [MINOR] Fix typos in HoodieTimelineArchiver (#7268)
dd1a2f544e is described below

commit dd1a2f544eb5046c3d455045e1edf0a0f858f0e9
Author: Y Ethan Guo <[email protected]>
AuthorDate: Tue Nov 22 13:42:37 2022 -0800

    [MINOR] Fix typos in HoodieTimelineArchiver (#7268)
---
 .../main/java/org/apache/hudi/client/HoodieTimelineArchiver.java | 9 ++++-----
 1 file changed, 4 insertions(+), 5 deletions(-)

diff --git 
a/hudi-client/hudi-client-common/src/main/java/org/apache/hudi/client/HoodieTimelineArchiver.java
 
b/hudi-client/hudi-client-common/src/main/java/org/apache/hudi/client/HoodieTimelineArchiver.java
index 2992f4abd4..5b50195d6d 100644
--- 
a/hudi-client/hudi-client-common/src/main/java/org/apache/hudi/client/HoodieTimelineArchiver.java
+++ 
b/hudi-client/hudi-client-common/src/main/java/org/apache/hudi/client/HoodieTimelineArchiver.java
@@ -64,7 +64,6 @@ import org.apache.avro.generic.IndexedRecord;
 import org.apache.hadoop.fs.FileStatus;
 import org.apache.hadoop.fs.FileSystem;
 import org.apache.hadoop.fs.Path;
-
 import org.apache.log4j.LogManager;
 import org.apache.log4j.Logger;
 
@@ -175,7 +174,7 @@ public class HoodieTimelineArchiver<T extends 
HoodieAvroPayload, I, K, O> {
         LOG.info("No Instants to archive");
       }
 
-      if (shouldMergeSmallArchiveFies()) {
+      if (shouldMergeSmallArchiveFiles()) {
         mergeArchiveFilesIfNecessary(context);
       }
       return success;
@@ -187,7 +186,7 @@ public class HoodieTimelineArchiver<T extends 
HoodieAvroPayload, I, K, O> {
     }
   }
 
-  public boolean shouldMergeSmallArchiveFies() {
+  public boolean shouldMergeSmallArchiveFiles() {
     return config.getArchiveMergeEnable() && 
!StorageSchemes.isAppendSupported(metaClient.getFs().getScheme());
   }
 
@@ -227,7 +226,7 @@ public class HoodieTimelineArchiver<T extends 
HoodieAvroPayload, I, K, O> {
       // after merge, delete the small archive files.
       deleteFilesParallelize(metaClient, candidateFiles, context, true);
       LOG.info("Success to delete replaced small archive files.");
-      // finally, delete archiveMergePlan which means merging small archive 
files operation is succeed.
+      // finally, delete archiveMergePlan which means merging small archive 
files operation is successful.
       metaClient.getFs().delete(planPath, false);
       LOG.info("Success to merge small archive files.");
     }
@@ -266,7 +265,7 @@ public class HoodieTimelineArchiver<T extends 
HoodieAvroPayload, I, K, O> {
    * @throws IOException
    */
   private void verifyLastMergeArchiveFilesIfNecessary(HoodieEngineContext 
context) throws IOException {
-    if (shouldMergeSmallArchiveFies()) {
+    if (shouldMergeSmallArchiveFiles()) {
       Path planPath = new Path(metaClient.getArchivePath(), 
HoodieArchivedTimeline.MERGE_ARCHIVE_PLAN_NAME);
       HoodieWrapperFileSystem fs = metaClient.getFs();
       // If plan exist, last merge small archive files was failed.

Reply via email to