[ISSUE #4795] replace this exception with log print and return false.

apache · Mar 20, 2024 · 5641606 · 5641606
1 parent 0250a89
commit 5641606
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/...java/org/apache/eventmesh/openconnect/offsetmgmt/api/storage/OffsetStorageWriterImpl.java b/...java/org/apache/eventmesh/openconnect/offsetmgmt/api/storage/OffsetStorageWriterImpl.java
@@ -84,7 +84,8 @@ private boolean isFlushing() {
      */
     public synchronized boolean beginFlush() {
         if (isFlushing()) {
-            throw new RuntimeException("OffsetStorageWriter is already flushing");
+            log.warn("OffsetStorageWriter is already flushing");
+            return false;
         }
         if (data.isEmpty()) {
             return false;