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 07:37:02 UTC
[iotdb] branch ml_0729_test_exp1_no_write updated: add put to queue 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 c383d2959a add put to queue log
c383d2959a is described below
commit c383d2959a5db92ac923c9cbbd10326fb8a6579a
Author: Jinrui.Zhang <xi...@gmail.com>
AuthorDate: Fri Aug 5 15:34:46 2022 +0800
add put to queue log
---
.../iotdb/consensus/multileader/logdispatcher/LogDispatcher.java | 3 ++-
1 file changed, 2 insertions(+), 1 deletion(-)
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 69bc57b294..956b9ba4b9 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
@@ -111,7 +111,7 @@ public class LogDispatcher {
List<ByteBuffer> serializedRequests = request.buildSerializedRequests();
threads.forEach(
thread -> {
- logger.debug(
+ logger.info(
"{}: Push a log to the queue, where the queue length is {}",
impl.getThisNode().getGroupId(),
thread.getPendingRequest().size());
@@ -123,6 +123,7 @@ public class LogDispatcher {
} catch (InterruptedException e) {
e.printStackTrace();
} finally {
+ logger.info("{}: Push a log to the queue, done", impl.getThisNode().getGroupId());
StepTracker.trace("putToQueueWaitingTime", putToQueueStartTime, System.nanoTime());
}
// if (thread