Fix length problem in dfs command

Intel-bigdata · Oct 8, 2018 · 0816267 · 0816267
1 parent ae75e6f
commit 0816267
Showing 1 changed file with 16 additions and 1 deletion.
diff --git a/...mart-hadoop-client-2.7/src/main/java/org/smartdata/hadoop/filesystem/SmartFileSystem.java b/...mart-hadoop-client-2.7/src/main/java/org/smartdata/hadoop/filesystem/SmartFileSystem.java
@@ -221,7 +221,16 @@ public FileStatus[] listStatus(Path p) throws IOException {
           newStatus.add(status);
         }
       } else {
-        newStatus.add(status);
+        FileState fileState = smartDFSClient.getFileState(getPathName(status.getPath()));
+        if (fileState instanceof CompressionFileState) {
+          long len = ((CompressionFileState) fileState).getOriginalLength();
+          newStatus.add(new FileStatus(len, status.isDirectory(), status.getReplication(),
+              status.getBlockSize(), status.getModificationTime(), status.getAccessTime(),
+              status.getPermission(), status.getOwner(), status.getGroup(),
+              status.isSymlink() ? status.getSymlink() : null, status.getPath()));
+        } else {
+          newStatus.add(status);
+        }
       }
     }
     return newStatus.toArray(new FileStatus[oldStatus.length]);
@@ -297,6 +306,12 @@ public FileStatus getFileLinkStatus(final Path f) throws IOException {
       if (fileState instanceof CompactFileState) {
         fileStatus = getFileStatus(target);
       }
+    } else {
+      Path target = getLinkTarget(f);
+      FileState fileState = smartDFSClient.getFileState(getPathName(target));
+      if (fileState instanceof CompressionFileState) {
+        fileStatus = getFileStatus(target);
+      }
     }
     return fileStatus;
   }