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.