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);

Reply via email to