You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by ta...@apache.org on 2022/01/14 05:29:31 UTC

[iotdb] branch rel/0.12 updated: fix a logical bug in processPlanLocally (#4810)

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

tanxinyu pushed a commit to branch rel/0.12
in repository https://gitbox.apache.org/repos/asf/iotdb.git


The following commit(s) were added to refs/heads/rel/0.12 by this push:
     new 9017331  fix a logical bug in processPlanLocally (#4810)
9017331 is described below

commit 9017331bdd07758f88c2b42adad290c2b02edc6f
Author: Mrquan <50...@users.noreply.github.com>
AuthorDate: Fri Jan 14 13:28:35 2022 +0800

    fix a logical bug in processPlanLocally (#4810)
    
    Co-authored-by: 权思屹 <si...@gmail.com>
---
 .../main/java/org/apache/iotdb/cluster/server/member/RaftMember.java  | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/cluster/src/main/java/org/apache/iotdb/cluster/server/member/RaftMember.java b/cluster/src/main/java/org/apache/iotdb/cluster/server/member/RaftMember.java
index 36794bd..87cae82 100644
--- a/cluster/src/main/java/org/apache/iotdb/cluster/server/member/RaftMember.java
+++ b/cluster/src/main/java/org/apache/iotdb/cluster/server/member/RaftMember.java
@@ -974,7 +974,7 @@ public abstract class RaftMember {
     // if a single log exceeds the threshold
     // we need to return error code to the client as in server mode
     if (ClusterDescriptor.getInstance().getConfig().isEnableRaftLogPersistence()
-        & log.serialize().capacity() + Integer.BYTES
+        && log.serialize().capacity() + Integer.BYTES
             >= ClusterDescriptor.getInstance().getConfig().getRaftLogBufferSize()) {
       logger.error(
           "Log cannot fit into buffer, please increase raft_log_buffer_size;"
@@ -1014,7 +1014,7 @@ public abstract class RaftMember {
     log.setPlan(plan);
     // just like processPlanLocally,we need to check the size of log
     if (ClusterDescriptor.getInstance().getConfig().isEnableRaftLogPersistence()
-        & log.serialize().capacity() + Integer.BYTES
+        && log.serialize().capacity() + Integer.BYTES
             >= ClusterDescriptor.getInstance().getConfig().getRaftLogBufferSize()) {
       logger.error(
           "Log cannot fit into buffer, please increase raft_log_buffer_size;"