This is an automated email from the ASF dual-hosted git repository.
jinrongtong pushed a change to branch 5.0.0-beta-dledger-controller
in repository https://gitbox.apache.org/repos/asf/rocketmq.git
from c3a3334e8 When enableSlaveActingMaster=false, automatic degradation is
not performed
add 940d8d825 Remove useless doAfterRpcFailure method in RPCHook (#4538)
add 13ffac892 Fix the offset not found and add some tests (#4504)
add 52d1c8cca Fix static topic test, await the client metadata to be
refreshed (#4500)
add ef37465e5 Fix bug that return IN_SYNC_REPLICAS_NOT_ENOUGH when
enableSlaveActingMaster is false (#4554)
add dde98ac2c Merge remote-tracking branch 'apache/5.0.0-beta' into
5.0.0-beta-dledger-controller
add 3d8296e3b When the controller is embedded in namesrv, the heartbeat of
namesrv is no longer reused
No new revisions were added by this update.
Summary of changes:
.travis.yml | 5 +-
.../rocketmq/acl/common/AclClientRPCHook.java | 4 -
.../apache/rocketmq/broker/BrokerController.java | 16 +--
.../rocketmq/client/impl/MQClientAPIImpl.java | 17 +--
.../store/RemoteBrokerOffsetStoreTest.java | 2 +-
.../org/apache/rocketmq/common/BrokerConfig.java | 13 --
.../apache/rocketmq/namesrv/NamesrvController.java | 75 +-----------
.../apache/rocketmq/namesrv/NamesrvStartup.java | 94 +++++++++++----
.../processor/ControllerRequestProcessor.java | 128 --------------------
.../namesrv/routeinfo/RouteInfoManager.java | 111 ++---------------
.../java/org/apache/rocketmq/remoting/RPCHook.java | 2 -
.../remoting/netty/NettyRemotingAbstract.java | 12 --
.../remoting/netty/NettyRemotingClient.java | 3 -
.../java/org/apache/rocketmq/store/CommitLog.java | 65 +++++-----
.../rocketmq/store/DefaultMessageStoreTest.java | 20 ++++
.../java/org/apache/rocketmq/store/HATest.java | 73 ++++++++++++
.../rocketmq/test/util/MQAdminTestUtils.java | 36 ++++++
.../AutoSwitchRoleIntegrationTest.java | 9 +-
.../org/apache/rocketmq/test/base/BaseConf.java | 19 +++
.../rocketmq/test/container/BrokerFailoverIT.java | 5 -
.../rocketmq/test/offset/OffsetNotFoundIT.java | 132 +++++++++++++++++++++
.../rocketmq/test/statictopic/StaticTopicIT.java | 63 ++++++++--
22 files changed, 470 insertions(+), 434 deletions(-)
delete mode 100644
namesrv/src/main/java/org/apache/rocketmq/namesrv/processor/ControllerRequestProcessor.java
create mode 100644
test/src/test/java/org/apache/rocketmq/test/offset/OffsetNotFoundIT.java
