This is an automated email from the ASF dual-hosted git repository.
justinchen pushed a commit to branch disruptor-log-13
in repository https://gitbox.apache.org/repos/asf/iotdb.git
The following commit(s) were added to refs/heads/disruptor-log-13 by this push:
new 0789808960b fx
0789808960b is described below
commit 0789808960ba16b800b9f27d5dbdbba846dbfe3f
Author: Caideyipi <[email protected]>
AuthorDate: Wed Mar 25 18:30:12 2026 +0800
fx
---
.../db/pipe/source/dataregion/realtime/assigner/DisruptorQueue.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/source/dataregion/realtime/assigner/DisruptorQueue.java
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/source/dataregion/realtime/assigner/DisruptorQueue.java
index c7add196e69..2a2fa110749 100644
---
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/source/dataregion/realtime/assigner/DisruptorQueue.java
+++
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/source/dataregion/realtime/assigner/DisruptorQueue.java
@@ -112,9 +112,9 @@ public class DisruptorQueue {
private void mayPrintExceedingLog() {
final long remainingCapacity = ringBuffer.remainingCapacity();
final long bufferSize = ringBuffer.getBufferSize();
- if ((double) remainingCapacity / bufferSize >= 0.5
+ if ((double) remainingCapacity / bufferSize <= 0.5
&& System.currentTimeMillis()
- -
PipeConfig.getInstance().getPipePeriodicalLogMinIntervalSeconds()
+ -
PipeConfig.getInstance().getPipePeriodicalLogMinIntervalSeconds() * 1000L
>= lastLogTime) {
LOGGER.warn(
"The assigner queue content has exceeded half, it may be stuck and
may block insertion. regionId: {}, capacity: {}, bufferSize: {}",
