set isStart to false

apache · Jan 16, 2023 · a94ec9c · a94ec9c
1 parent c79f920
commit a94ec9c
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/hudi-common/src/main/java/org/apache/hudi/common/util/queue/DisruptorMessageQueue.java b/hudi-common/src/main/java/org/apache/hudi/common/util/queue/DisruptorMessageQueue.java
@@ -97,6 +97,7 @@ public void close() {
     synchronized (this) {
       if (!isShutdown) {
         isShutdown = true;
+        isStart = false;
         queue.shutdown();
       }
     }