You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@inlong.apache.org by go...@apache.org on 2022/03/21 01:29:54 UTC
[incubator-inlong] branch master updated (86319d8 -> a5416ce)
This is an automated email from the ASF dual-hosted git repository.
gosonzhang pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-inlong.git.
from 86319d8 [INLONG-3252][Manager] Remove repeated-read transaction in the getting source method (#3253)
add a5416ce [INLONG-3254][TubeMQ]Replace the call of MetaDataManager with DefaultMetaDataService (#3255)
No new revisions were added by this update.
Summary of changes:
inlong-tubemq/conf/master.ini | 2 +-
.../server/common/paramcheck/PBParameterUtils.java | 8 +-
.../server/common/utils/WebParameterUtils.java | 8 +-
.../inlong/tubemq/server/master/TMaster.java | 71 +-
.../server/master/balance/DefaultLoadBalancer.java | 28 +-
.../tubemq/server/master/balance/LoadBalancer.java | 11 +-
.../server/master/metamanage/MetaDataManager.java | 2061 --------------------
.../metamanage/metastore/MetaStoreService.java | 300 ---
.../impl/bdbimpl/BdbMetaStoreServiceImpl.java | 1344 -------------
.../impl/zkimpl/ZKMetaConfigMapperImpl.java | 10 +
.../nodemanage/nodebroker/BrokerAbnHolder.java | 17 +-
.../nodemanage/nodebroker/DefBrokerRunManager.java | 25 +-
.../server/master/web/MasterStatusCheckFilter.java | 12 +-
.../server/master/web/action/screen/Master.java | 14 +-
.../server/master/web/action/screen/Tubeweb.java | 8 +-
.../server/master/web/action/screen/Webapi.java | 10 +-
.../web/action/screen/cluster/ClusterManager.java | 8 +-
.../web/action/screen/config/BrokerList.java | 2 +-
.../master/web/handler/AbstractWebHandler.java | 6 +-
.../web/handler/WebAdminFlowRuleHandler.java | 6 +-
.../web/handler/WebAdminGroupCtrlHandler.java | 82 +-
.../web/handler/WebAdminTopicAuthHandler.java | 14 +-
.../master/web/handler/WebBrokerConfHandler.java | 83 +-
.../web/handler/WebGroupConsumeCtrlHandler.java | 22 +-
.../master/web/handler/WebGroupResCtrlHandler.java | 18 +-
.../master/web/handler/WebMasterInfoHandler.java | 16 +-
.../master/web/handler/WebTopicCtrlHandler.java | 12 +-
.../master/web/handler/WebTopicDeployHandler.java | 34 +-
.../server/master/web/simplemvc/ControlTool.java | 2 +-
.../master/web/simplemvc/RequestContext.java | 6 +-
.../web/simplemvc/VelocityTemplateEngine.java | 4 +-
31 files changed, 285 insertions(+), 3959 deletions(-)
delete mode 100644 inlong-tubemq/tubemq-server/src/main/java/org/apache/inlong/tubemq/server/master/metamanage/MetaDataManager.java
delete mode 100644 inlong-tubemq/tubemq-server/src/main/java/org/apache/inlong/tubemq/server/master/metamanage/metastore/MetaStoreService.java
delete mode 100644 inlong-tubemq/tubemq-server/src/main/java/org/apache/inlong/tubemq/server/master/metamanage/metastore/impl/bdbimpl/BdbMetaStoreServiceImpl.java