[ISSUE #4795] Replace this exception in beginFlush() with log print a…

…nd return false (#4797)
apache · Mar 20, 2024 · df1428f · df1428f
1 parent 291d748
commit df1428f
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;