remove fs close

apache · Dec 20, 2024 · 240393c · 240393c
1 parent c150558
commit 240393c
Showing 1 changed file with 2 additions and 3 deletions.
diff --git a/...r-yarn/src/main/scala/org/apache/kyuubi/spark/connector/yarn/YarnLogPartitionReader.scala b/...r-yarn/src/main/scala/org/apache/kyuubi/spark/connector/yarn/YarnLogPartitionReader.scala
@@ -49,9 +49,7 @@ class YarnLogPartitionReader(yarnLogPartition: YarnLogPartition)
       UTF8String.fromString(yarnLog.message)))
   }
 
-  override def close(): Unit = {
-    fs.close()
-  }
+  override def close(): Unit = {}
 
   /**
    * fet log
@@ -107,6 +105,7 @@ class YarnLogPartitionReader(yarnLogPartition: YarnLogPartition)
         } finally {
           IOUtils.closeStream(inputStream)
           reader.close()
+          fs.close()
         }
       case _ => Seq.empty
     }