This is an automated email from the ASF dual-hosted git repository.
danny0405 pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/hudi.git
The following commit(s) were added to refs/heads/master by this push:
new 913c320e4a5 [MINOR] Fix BUG: HoodieLogFormatWriter: unable to close
output stream for log file HoodieLogFile{xxx} (#10989)
913c320e4a5 is described below
commit 913c320e4a5e46b59b06b38821813b270349a918
Author: Silly Carbon <[email protected]>
AuthorDate: Wed Apr 10 18:21:57 2024 +0800
[MINOR] Fix BUG: HoodieLogFormatWriter: unable to close output stream for
log file HoodieLogFile{xxx} (#10989)
* due to java.lang.IllegalStateException: Shutdown in progress, cause:
when `org.apache.hudi.common.table.log.HoodieLogFormatWriter.close`
tries to `removeShutdownHook`, hooks were already removed by JVM when triggered
(hooks == null)
---
.../java/org/apache/hudi/common/table/log/HoodieLogFormatWriter.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git
a/hudi-common/src/main/java/org/apache/hudi/common/table/log/HoodieLogFormatWriter.java
b/hudi-common/src/main/java/org/apache/hudi/common/table/log/HoodieLogFormatWriter.java
index 4e5082d4541..1db4c1b7868 100644
---
a/hudi-common/src/main/java/org/apache/hudi/common/table/log/HoodieLogFormatWriter.java
+++
b/hudi-common/src/main/java/org/apache/hudi/common/table/log/HoodieLogFormatWriter.java
@@ -278,7 +278,7 @@ public class HoodieLogFormatWriter implements
HoodieLogFormat.Writer {
try {
LOG.warn("running logformatwriter hook");
if (output != null) {
- close();
+ closeStream();
}
} catch (Exception e) {
LOG.warn("unable to close output stream for log file " + logFile, e);