From 50fa5a6aa75ac506a326450f115c986e5e5f9ea0 Mon Sep 17 00:00:00 2001
From: hehexiaoduantui <991413521@qq.com>
Date: Thu, 6 Jan 2022 15:49:30 +0800
Subject: [PATCH] Update HiveIncrementalPuller to configure filesystem (#4431)

* Update HiveIncrementalPuller.java

fix get FileSystem bug

* Update HiveIncrementalPuller.java

fix error

* Update HiveIncrementalPuller.java

fie error
---
 .../java/org/apache/hudi/utilities/HiveIncrementalPuller.java  | 3 +++
 1 file changed, 3 insertions(+)

diff --git a/hudi-utilities/src/main/java/org/apache/hudi/utilities/HiveIncrementalPuller.java b/hudi-utilities/src/main/java/org/apache/hudi/utilities/HiveIncrementalPuller.java
index 0cd80419d..e5d630df5 100644
--- a/hudi-utilities/src/main/java/org/apache/hudi/utilities/HiveIncrementalPuller.java
+++ b/hudi-utilities/src/main/java/org/apache/hudi/utilities/HiveIncrementalPuller.java
@@ -91,6 +91,8 @@ public class HiveIncrementalPuller {
     public String fromCommitTime;
     @Parameter(names = {"--maxCommits"})
     public int maxCommits = 3;
+    @Parameter(names = {"--fsDefaultFs"})
+    public String fsDefaultFs = "file:///";
     @Parameter(names = {"--help", "-h"}, help = true)
     public Boolean help = false;
   }
@@ -124,6 +126,7 @@ public class HiveIncrementalPuller {
 
   public void saveDelta() throws IOException {
     Configuration conf = new Configuration();
+    conf.set("fs.defaultFS",config.fsDefaultFs);
     FileSystem fs = FileSystem.get(conf);
     Statement stmt = null;
     try {