[iotdb] branch native_raft updated: use compression for delayed dispatcher groups

[jiangtian]

This is an automated email from the ASF dual-hosted git repository.

jiangtian pushed a commit to branch native_raft
in repository https://gitbox.apache.org/repos/asf/iotdb.git


The following commit(s) were added to refs/heads/native_raft by this push:
     new 0c2fef70c03 use compression for delayed dispatcher groups
0c2fef70c03 is described below

commit 0c2fef70c03557eb96f9d83491257ed87190549a
Author: Tian Jiang <jt2594...@163.com>
AuthorDate: Mon May 29 08:56:20 2023 +0800

    use compression for delayed dispatcher groups
---
 .../iotdb/consensus/natraft/protocol/log/dispatch/DispatcherThread.java | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/consensus/src/main/java/org/apache/iotdb/consensus/natraft/protocol/log/dispatch/DispatcherThread.java
 
b/consensus/src/main/java/org/apache/iotdb/consensus/natraft/protocol/log/dispatch/DispatcherThread.java
index 60746935feb..694a1eb99ea 100644
--- 
a/consensus/src/main/java/org/apache/iotdb/consensus/natraft/protocol/log/dispatch/DispatcherThread.java
+++ 
b/consensus/src/main/java/org/apache/iotdb/consensus/natraft/protocol/log/dispatch/DispatcherThread.java
@@ -238,7 +238,7 @@ class DispatcherThread extends DynamicThread {
             entry.getEntry().createTime);
       }
 
-      if (!logDispatcher.enableCompressedDispatching) {
+      if (!logDispatcher.enableCompressedDispatching && !group.isDelayed()) {
         AppendEntriesRequest appendEntriesRequest = prepareRequest(logList);
         appendEntriesAsync(logList, appendEntriesRequest, 
currBatch.subList(prevIndex, logIndex));
       } else {