From 62bb9e10d9d2f2a9807ee46b0ed094ef2fcc89e5 Mon Sep 17 00:00:00 2001
From: Roc Marshal <64569824+RocMarshal@users.noreply.github.com>
Date: Thu, 15 Apr 2021 09:40:14 +0800
Subject: [PATCH] [Hotfix][utilities] Optimized codes (#2821)

---
 .../org/apache/hudi/utilities/HDFSParquetImporter.java    | 2 +-
 ...nitialCheckpointFromAnotherHoodieTimelineProvider.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 186479541..c9955bdb1 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 e2554c4d4..ea366d647 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) {