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/08 03:05:34 UTC
[iotdb] branch ml_0729_test_exp1_no_write updated: add log if the request cannot be put into queue
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 6bd7b20476 add log if the request cannot be put into queue
6bd7b20476 is described below
commit 6bd7b204767dea1512801beb468e3ae6d610956f
Author: Jinrui.Zhang <xi...@gmail.com>
AuthorDate: Mon Aug 8 11:05:23 2022 +0800
add log if the request cannot be put into queue
---
.../iotdb/consensus/multileader/logdispatcher/LogDispatcher.java | 7 ++++---
1 file changed, 4 insertions(+), 3 deletions(-)
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 eeecfcfaa6..aa4091f708 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
@@ -138,10 +138,11 @@ public class LogDispatcher {
.offer(new IndexedConsensusRequest(serializedRequests, request.getSearchIndex()))) {
thread.countQueue(request.getSearchIndex());
} else {
- logger.debug(
- "{}: Log queue of {} is full, ignore the log to this node",
+ logger.info(
+ "{}: Log queue of {} is full, ignore the log to this node, searchIndex: {}",
impl.getThisNode().getGroupId(),
- thread.getPeer());
+ thread.getPeer(),
+ request.getSearchIndex());
}
});
}