You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hudi.apache.org by fo...@apache.org on 2023/01/04 03:32:49 UTC
[hudi] 39/45: [HUDI-5350] Fix oom cause compaction event lost problem (#7408)
This is an automated email from the ASF dual-hosted git repository.
forwardxu pushed a commit to branch release-0.12.1
in repository https://gitbox.apache.org/repos/asf/hudi.git
commit e0faa0bbe1021204281e5dccc51fb99610326987
Author: Bingeng Huang <30...@qq.com>
AuthorDate: Fri Dec 9 15:24:29 2022 +0800
[HUDI-5350] Fix oom cause compaction event lost problem (#7408)
Co-authored-by: hbg <bi...@shopee.com>
(cherry picked from commit 115584c46e30998e0369b0e5550cc60eac8295ab)
---
.../main/java/org/apache/hudi/sink/utils/NonThrownExecutor.java | 8 ++++----
1 file changed, 4 insertions(+), 4 deletions(-)
diff --git a/hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/utils/NonThrownExecutor.java b/hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/utils/NonThrownExecutor.java
index 4364d1d16d..4ed1716545 100644
--- a/hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/utils/NonThrownExecutor.java
+++ b/hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/utils/NonThrownExecutor.java
@@ -136,15 +136,15 @@ public class NonThrownExecutor implements AutoCloseable {
}
private void handleException(Throwable t, ExceptionHook hook, Supplier<String> actionString) {
- // if we have a JVM critical error, promote it immediately, there is a good
- // chance the
- // logging or job failing will not succeed any more
- ExceptionUtils.rethrowIfFatalErrorOrOOM(t);
final String errMsg = String.format("Executor executes action [%s] error", actionString.get());
logger.error(errMsg, t);
if (hook != null) {
hook.apply(errMsg, t);
}
+ // if we have a JVM critical error, promote it immediately, there is a good
+ // chance the
+ // logging or job failing will not succeed any more
+ ExceptionUtils.rethrowIfFatalErrorOrOOM(t);
}
private Supplier<String> getActionString(String actionName, Object... actionParams) {