You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by xi...@apache.org on 2022/08/05 11:09:54 UTC
[iotdb] branch ml_0729_test_exp1_no_write updated: add more log
This is an automated email from the ASF dual-hosted git repository.
xingtanzjr pushed a commit to branch ml_0729_test_exp1_no_write
in repository https://gitbox.apache.org/repos/asf/iotdb.git
The following commit(s) were added to refs/heads/ml_0729_test_exp1_no_write by this push:
new 7e92f11705 add more log
7e92f11705 is described below
commit 7e92f117057d10eb268bd1c2889c7608ee816520
Author: Jinrui.Zhang <xi...@gmail.com>
AuthorDate: Fri Aug 5 19:09:42 2022 +0800
add more log
---
.../iotdb/consensus/multileader/logdispatcher/LogDispatcher.java | 5 +++++
1 file changed, 5 insertions(+)
diff --git a/consensus/src/main/java/org/apache/iotdb/consensus/multileader/logdispatcher/LogDispatcher.java b/consensus/src/main/java/org/apache/iotdb/consensus/multileader/logdispatcher/LogDispatcher.java
index ac941e6453..ef72907d35 100644
--- a/consensus/src/main/java/org/apache/iotdb/consensus/multileader/logdispatcher/LogDispatcher.java
+++ b/consensus/src/main/java/org/apache/iotdb/consensus/multileader/logdispatcher/LogDispatcher.java
@@ -394,6 +394,11 @@ public class LogDispatcher {
&& logBatches.size() < config.getReplication().getMaxRequestPerBatch()) {
logger.debug("construct from WAL for one Entry, index : {}", currentIndex);
try {
+ logger.debug(
+ "{} : before wait pendingRequest Size: {}, bufferedRequest size: {}",
+ impl.getThisNode().getGroupId(),
+ pendingRequest.size(),
+ bufferedRequest.size());
walEntryiterator.waitForNextReady();
} catch (InterruptedException e) {
Thread.currentThread().interrupt();