[bugfix][plugin][doriswriter] Fix memory overflow causing task proces…

…s to block
wgzhao · Dec 14, 2024 · d42aec3 · d42aec3
1 parent 50440b9
commit d42aec3
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/...iswriter/src/main/java/com/wgzhao/addax/plugin/writer/doriswriter/DorisWriterManager.java b/...iswriter/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;
                     }
                 }