[incubator-tubemq] branch master updated: [TUBEMQ-577] reload status output and topic config output mismatch

[dockerzhang]

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

dockerzhang pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-tubemq.git


The following commit(s) were added to refs/heads/master by this push:
     new 803ce9a  [TUBEMQ-577] reload status output and topic config output 
mismatch
803ce9a is described below

commit 803ce9a029e88522ce99e2fde44d2ba11a22f27a
Author: gosonzhang <gosonzh...@tencent.com>
AuthorDate: Mon Mar 15 16:29:43 2021 +0800

    [TUBEMQ-577] reload status output and topic config output mismatch
---
 .../server/master/nodemanage/nodebroker/BrokerSyncStatusInfo.java       | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/tubemq-server/src/main/java/org/apache/tubemq/server/master/nodemanage/nodebroker/BrokerSyncStatusInfo.java
 
b/tubemq-server/src/main/java/org/apache/tubemq/server/master/nodemanage/nodebroker/BrokerSyncStatusInfo.java
index 83e2794..83bcfbb 100644
--- 
a/tubemq-server/src/main/java/org/apache/tubemq/server/master/nodemanage/nodebroker/BrokerSyncStatusInfo.java
+++ 
b/tubemq-server/src/main/java/org/apache/tubemq/server/master/nodemanage/nodebroker/BrokerSyncStatusInfo.java
@@ -744,7 +744,7 @@ public class BrokerSyncStatusInfo {
                 tmpmemCacheFlushIntvl = Integer.parseInt(topicConfInfoArr[13]);
             }
             if (topicConfInfoArr.length > 14) {
-                if (!TStringUtils.isNotBlank(topicConfInfoArr[14])) {
+                if (TStringUtils.isNotBlank(topicConfInfoArr[14])) {
                     tmpMaxMsgSize = Integer.parseInt(topicConfInfoArr[14]);
                     Tuple2<Integer, Integer> calcResult =
                             ClusterConfigHolder.calcMaxMsgSize(tmpMaxMsgSize);