[hudi] branch master updated: [Hotfix][utilities] Optimized codes (#2821)

[wangxianghu]

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

wangxianghu 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 62bb9e1  [Hotfix][utilities] Optimized codes (#2821)
62bb9e1 is described below

commit 62bb9e10d9d2f2a9807ee46b0ed094ef2fcc89e5
Author: Roc Marshal <64569824+rocmars...@users.noreply.github.com>
AuthorDate: Thu Apr 15 09:40:14 2021 +0800

    [Hotfix][utilities] Optimized codes (#2821)
---
 .../main/java/org/apache/hudi/utilities/HDFSParquetImporter.java  | 2 +-
 .../InitialCheckpointFromAnotherHoodieTimelineProvider.java       | 8 ++++----
 2 files changed, 5 insertions(+), 5 deletions(-)

diff --git 
a/hudi-utilities/src/main/java/org/apache/hudi/utilities/HDFSParquetImporter.java
 
b/hudi-utilities/src/main/java/org/apache/hudi/utilities/HDFSParquetImporter.java
index 1864795..c9955bd 100644
--- 
a/hudi-utilities/src/main/java/org/apache/hudi/utilities/HDFSParquetImporter.java
+++ 
b/hudi-utilities/src/main/java/org/apache/hudi/utilities/HDFSParquetImporter.java
@@ -102,7 +102,7 @@ public class HDFSParquetImporter implements Serializable {
   }
 
   private boolean isUpsert() {
-    return "upsert".equals(cfg.command.toLowerCase());
+    return "upsert".equalsIgnoreCase(cfg.command);
   }
 
   public int dataImport(JavaSparkContext jsc, int retry) {
diff --git 
a/hudi-utilities/src/main/java/org/apache/hudi/utilities/checkpointing/InitialCheckpointFromAnotherHoodieTimelineProvider.java
 
b/hudi-utilities/src/main/java/org/apache/hudi/utilities/checkpointing/InitialCheckpointFromAnotherHoodieTimelineProvider.java
index e2554c4..ea366d6 100644
--- 
a/hudi-utilities/src/main/java/org/apache/hudi/utilities/checkpointing/InitialCheckpointFromAnotherHoodieTimelineProvider.java
+++ 
b/hudi-utilities/src/main/java/org/apache/hudi/utilities/checkpointing/InitialCheckpointFromAnotherHoodieTimelineProvider.java
@@ -35,7 +35,7 @@ import static 
org.apache.hudi.utilities.deltastreamer.HoodieDeltaStreamer.CHECKP
  */
 public class InitialCheckpointFromAnotherHoodieTimelineProvider extends 
InitialCheckPointProvider {
 
-  private HoodieTableMetaClient anotherDsHoodieMetaclient;
+  private HoodieTableMetaClient anotherDsHoodieMetaClient;
 
   public InitialCheckpointFromAnotherHoodieTimelineProvider(TypedProperties 
props) {
     super(props);
@@ -44,16 +44,16 @@ public class 
InitialCheckpointFromAnotherHoodieTimelineProvider extends InitialC
   @Override
   public void init(Configuration config) throws HoodieException {
     super.init(config);
-    this.anotherDsHoodieMetaclient = 
HoodieTableMetaClient.builder().setConf(config).setBasePath(path.toString()).build();
+    this.anotherDsHoodieMetaClient = 
HoodieTableMetaClient.builder().setConf(config).setBasePath(path.toString()).build();
   }
 
   @Override
   public String getCheckpoint() throws HoodieException {
-    return 
anotherDsHoodieMetaclient.getCommitsTimeline().filterCompletedInstants().getReverseOrderedInstants()
+    return 
anotherDsHoodieMetaClient.getCommitsTimeline().filterCompletedInstants().getReverseOrderedInstants()
         .map(instant -> {
           try {
             HoodieCommitMetadata commitMetadata = HoodieCommitMetadata
-                
.fromBytes(anotherDsHoodieMetaclient.getActiveTimeline().getInstantDetails(instant).get(),
+                
.fromBytes(anotherDsHoodieMetaClient.getActiveTimeline().getInstantDetails(instant).get(),
                     HoodieCommitMetadata.class);
             return commitMetadata.getMetadata(CHECKPOINT_KEY);
           } catch (IOException e) {