From d42aec35cd0a6cc17424e0f2d1645e7e81cb0a6b Mon Sep 17 00:00:00 2001
From: wgzhao <wgzhao@gmail.com>
Date: Sat, 14 Dec 2024 13:47:27 +0800
Subject: [PATCH] [bugfix][plugin][doriswriter] Fix memory overflow causing
 task process to block

---
 .../addax/plugin/writer/doriswriter/DorisWriterManager.java | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)

diff --git a/plugin/writer/doriswriter/src/main/java/com/wgzhao/addax/plugin/writer/doriswriter/DorisWriterManager.java b/plugin/writer/doriswriter/src/main/java/com/wgzhao/addax/plugin/writer/doriswriter/DorisWriterManager.java
index 505b5fa64..496574010 100644
--- a/plugin/writer/doriswriter/src/main/java/com/wgzhao/addax/plugin/writer/doriswriter/DorisWriterManager.java
+++ b/plugin/writer/doriswriter/src/main/java/com/wgzhao/addax/plugin/writer/doriswriter/DorisWriterManager.java
@@ -48,7 +48,7 @@ public class DorisWriterManager {
     private int batchCount = 0;
     private long batchSize = 0;
     private volatile boolean closed = false;
-    private volatile Exception flushException;
+    private volatile Throwable flushException;
     private final LinkedBlockingDeque< WriterTuple > flushQueue;
     private ScheduledExecutorService scheduler;
     private ScheduledFuture<?> scheduledFuture;
@@ -74,7 +74,7 @@ public void startScheduler() {
                             startScheduler();
                         }
                         flush(label, false);
-                    } catch (Exception e) {
+                    } catch (Throwable e) {
                         flushException = e;
                     }
                 }
@@ -149,7 +149,7 @@ public void run() {
                 while(true) {
                     try {
                         asyncFlush();
-                    } catch (Exception e) {
+                    } catch (Throwable e) {
                         flushException = e;
                     }
                 }