Revert "Wrapper the input and oupput stream from HadoopExtendedFileSy…

…stem" This reverts commit 195ce18.
cjjxfli · Mar 9, 2022 · 1066c99 · 1066c99
1 parent 7e138de
commit 1066c99
Showing 1 changed file with 6 additions and 6 deletions.
diff --git a/presto-hive-common/src/main/java/org/apache/hadoop/fs/HadoopExtendedFileSystem.java b/presto-hive-common/src/main/java/org/apache/hadoop/fs/HadoopExtendedFileSystem.java
@@ -125,15 +125,15 @@ public Path resolvePath(final Path p)
     public FSDataInputStream open(Path f, int bufferSize)
             throws IOException
     {
-        return new InputStreamWrapper(getRawFileSystem().open(f, bufferSize), this);
+        return fs.open(f, bufferSize);
     }
 
     @Override
     public FSDataOutputStream append(Path f, int bufferSize,
             Progressable progress)
             throws IOException
     {
-        return new OutputStreamWrapper(getRawFileSystem().append(f, bufferSize, progress), this);
+        return fs.append(f, bufferSize, progress);
     }
 
     @Override
@@ -149,7 +149,7 @@ public FSDataOutputStream create(Path f, FsPermission permission,
             Progressable progress)
             throws IOException
     {
-        return new OutputStreamWrapper(getRawFileSystem().create(f, permission, overwrite, bufferSize, replication, blockSize, progress), this);
+        return fs.create(f, permission, overwrite, bufferSize, replication, blockSize, progress);
     }
 
     @Override
@@ -163,7 +163,7 @@ public FSDataOutputStream create(Path f,
             Options.ChecksumOpt checksumOpt)
             throws IOException
     {
-        return new OutputStreamWrapper(getRawFileSystem().create(f, permission, flags, bufferSize, replication, blockSize, progress, checksumOpt), this);
+        return fs.create(f, permission, flags, bufferSize, replication, blockSize, progress, checksumOpt);
     }
 
     @Override
@@ -173,7 +173,7 @@ public FSDataOutputStream createNonRecursive(Path f, FsPermission permission,
             Progressable progress)
             throws IOException
     {
-        return new OutputStreamWrapper(getRawFileSystem().createNonRecursive(f, permission, flags, bufferSize, replication, blockSize, progress), this);
+        return fs.createNonRecursive(f, permission, flags, bufferSize, replication, blockSize, progress);
     }
 
     @Override
@@ -629,6 +629,6 @@ public RemoteIterator<LocatedFileStatus> listDirectory(Path path)
     public FSDataInputStream openFile(Path path, HiveFileContext hiveFileContext)
             throws Exception
     {
-        return new InputStreamWrapper(getRawFileSystem().open(path), this);
+        return fs.open(path);
     }
 }