Fix the HDFS root path

google · Aug 23, 2024 · 5f0926e · 5f0926e
1 parent 5a8bae6
commit 5f0926e
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...e/edwmigration/dumper/application/dumper/connector/hdfs/HdfsPermissionExtractionTask.java b/...e/edwmigration/dumper/application/dumper/connector/hdfs/HdfsPermissionExtractionTask.java
@@ -66,7 +66,7 @@ public String getTargetPath() {
   protected Void doRun(TaskRunContext context, @Nonnull ByteSink sink, @Nonnull Handle handle)
       throws IOException, ExecutionException, InterruptedException {
     DistributedFileSystem fs = ((HdfsHandle) handle).getDfs();
-    String hdfsPath = "/user/hive";
+    String hdfsPath = "/";
     org.apache.hadoop.fs.ContentSummary contentSummary = fs.getContentSummary(new Path(hdfsPath));
     ExecutorService execService =
         ExecutorManager.newExecutorServiceWithBackpressure("hdfs-permission-extraction", poolSize);