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) {