This is an automated email from the ASF dual-hosted git repository.
peacewong pushed a commit to branch dev-1.4.0
in repository https://gitbox.apache.org/repos/asf/linkis.git
The following commit(s) were added to refs/heads/dev-1.4.0 by this push:
new 581ce1e67 [fix bug] The s3a file cannot be written because FileSystem
is closed prematurely (#4375)
581ce1e67 is described below
commit 581ce1e6778d96b126d9318b8c27ed0c55903f2f
Author: 野鹿 <[email protected]>
AuthorDate: Thu Mar 16 19:57:15 2023 +0800
[fix bug] The s3a file cannot be written because FileSystem is closed
prematurely (#4375)
https://github.com/apache/linkis/issues/4374
---
.../org/apache/linkis/storage/resultset/StorageResultSetWriter.scala | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git
a/linkis-commons/linkis-storage/src/main/scala/org/apache/linkis/storage/resultset/StorageResultSetWriter.scala
b/linkis-commons/linkis-storage/src/main/scala/org/apache/linkis/storage/resultset/StorageResultSetWriter.scala
index 9c7947272..50bc0d276 100644
---
a/linkis-commons/linkis-storage/src/main/scala/org/apache/linkis/storage/resultset/StorageResultSetWriter.scala
+++
b/linkis-commons/linkis-storage/src/main/scala/org/apache/linkis/storage/resultset/StorageResultSetWriter.scala
@@ -187,11 +187,11 @@ class StorageResultSetWriter[K <: MetaData, V <: Record](
}
}
Utils.tryFinally(if (outputStream != null) flush()) {
- closeFs
if (outputStream != null) {
IOUtils.closeQuietly(outputStream)
outputStream = null
}
+ closeFs
}
}
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
