[Hotfix][utilities] Optimized codes (#2821)
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 @@
}
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 @@
*/
public class InitialCheckpointFromAnotherHoodieTimelineProvider extends InitialCheckPointProvider {
- private HoodieTableMetaClient anotherDsHoodieMetaclient;
+ private HoodieTableMetaClient anotherDsHoodieMetaClient;
public InitialCheckpointFromAnotherHoodieTimelineProvider(TypedProperties props) {
super(props);
@@ -44,16 +44,16 @@
@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) {
