You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by ju...@apache.org on 2026/03/23 10:50:50 UTC
(iotdb) branch opc-fix-fix updated: fix-disruptor
This is an automated email from the ASF dual-hosted git repository.
justinchen pushed a commit to branch opc-fix-fix
in repository https://gitbox.apache.org/repos/asf/iotdb.git
The following commit(s) were added to refs/heads/opc-fix-fix by this push:
new fd994e92eeb fix-disruptor
fd994e92eeb is described below
commit fd994e92eeb5176f2e90e42ca7de9ef13e8f4074
Author: Caideyipi <87...@users.noreply.github.com>
AuthorDate: Mon Mar 23 18:50:39 2026 +0800
fix-disruptor
---
.../db/pipe/source/dataregion/realtime/assigner/DisruptorQueue.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
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 52007765fe3..1249c43b21a 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
@@ -109,7 +109,7 @@ 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()
>= lastLogTime) {