diff --git a/bin/env.cmd b/bin/env.cmd index df52f5de034..248a76280fe 100644 --- a/bin/env.cmd +++ b/bin/env.cmd @@ -28,4 +28,4 @@ set JAVA="%JAVA_HOME%\bin\java" REM One may add extra Java runtime flags in addition to each role: Master or Broker set MASTER_JVM_OPTS=-Xmx1g -Xms256m -server -set BROKER_JVM_OPTS=-Xmx1g -Xms512m -server \ No newline at end of file +set BROKER_JVM_OPTS=-Xmx1g -Xms512g -server \ No newline at end of file diff --git a/tubemq-server/src/main/java/org/apache/tubemq/server/master/web/handler/WebBrokerDefConfHandler.java b/tubemq-server/src/main/java/org/apache/tubemq/server/master/web/handler/WebBrokerDefConfHandler.java index e131d2f7e55..5e5df369836 100644 --- a/tubemq-server/src/main/java/org/apache/tubemq/server/master/web/handler/WebBrokerDefConfHandler.java +++ b/tubemq-server/src/main/java/org/apache/tubemq/server/master/web/handler/WebBrokerDefConfHandler.java @@ -1218,7 +1218,6 @@ public StringBuilder adminQueryBrokerRunStatusInfo(HttpServletRequest req) throw StringBuilder strBuffer = new StringBuilder(512); try { BdbBrokerConfEntity brokerConfEntity = new BdbBrokerConfEntity(); - brokerConfEntity.setDftUnFlushDataHold(TBaseConstants.META_VALUE_UNDEFINED); boolean withDetail = WebParameterUtils.validBooleanDataParameter("withDetail", req.getParameter("withDetail"), false, false); @@ -1403,7 +1402,6 @@ public StringBuilder adminQueryBrokerRunStatusInfo(HttpServletRequest req) throw public StringBuilder adminQueryBrokerDefConfEntityInfo(HttpServletRequest req) throws Exception { StringBuilder strBuffer = new StringBuilder(512); BdbBrokerConfEntity brokerConfEntity = new BdbBrokerConfEntity(); - brokerConfEntity.setDftUnFlushDataHold(TBaseConstants.META_VALUE_UNDEFINED); try { brokerConfEntity .setRecordCreateUser(WebParameterUtils.validStringParameter("createUser", diff --git a/tubemq-server/src/main/java/org/apache/tubemq/server/master/web/handler/WebBrokerTopicConfHandler.java b/tubemq-server/src/main/java/org/apache/tubemq/server/master/web/handler/WebBrokerTopicConfHandler.java index f71e0c7d67b..1120a216175 100644 --- a/tubemq-server/src/main/java/org/apache/tubemq/server/master/web/handler/WebBrokerTopicConfHandler.java +++ b/tubemq-server/src/main/java/org/apache/tubemq/server/master/web/handler/WebBrokerTopicConfHandler.java @@ -1051,7 +1051,6 @@ public StringBuilder adminQueryBrokerTopicCfgAndRunInfo( webTopicEntity.setMemCacheMsgSizeInMB(TBaseConstants.META_VALUE_UNDEFINED); webTopicEntity.setMemCacheMsgCntInK(TBaseConstants.META_VALUE_UNDEFINED); webTopicEntity.setMemCacheFlushIntvl(TBaseConstants.META_VALUE_UNDEFINED); - webTopicEntity.setUnflushDataHold(TBaseConstants.META_VALUE_UNDEFINED); Map totalBrokers = brokerConfManager.getBrokerConfStoreMap(); Map brokerSyncStatusInfoMap =