You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@inlong.apache.org by do...@apache.org on 2022/03/07 06:13:49 UTC
[incubator-inlong] branch master updated (985b24a -> 668eb18)

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

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


    from 985b24a  [INLONG-2383][SDK] Support Kafka to consume PB compressed message protocol (#2797)
     add 668eb18  [INLONG-2955][TubeMQ] Adjust the offsetstorage and zookeeper package paths (#2958)

No new revisions were added by this update.

Summary of changes:
 LICENSE                                            |  10 +-
 .../tubemq/server/broker/BrokerServiceServer.java  |   2 +-
 .../server/broker/offset/DefaultOffsetManager.java |  30 +++---
 .../tubemq/server/broker/offset/OffsetService.java |   2 +-
 .../offset}/offsetstorage/OffsetStorage.java       |   2 +-
 .../offset}/offsetstorage/OffsetStorageInfo.java   |   2 +-
 .../offset}/offsetstorage/ZkOffsetStorage.java     |  76 ++++++-------
 .../{offsetstorage => }/zookeeper/Abortable.java   |   2 +-
 .../zookeeper/RecoverableZooKeeper.java            |   2 +-
 .../zookeeper/RetryCounter.java                    |   2 +-
 .../zookeeper/RetryCounterFactory.java             |   2 +-
 .../{offsetstorage => }/zookeeper/ZKUtil.java      | 119 +++++++++++----------
 .../zookeeper/ZooKeeperConnectionException.java    |   2 +-
 .../zookeeper/ZooKeeperListener.java               |   2 +-
 .../zookeeper/ZooKeeperWatcher.java                |   2 +-
 .../inlong/tubemq/server/master/TMaster.java       |  12 +--
 .../server/master/balance/DefaultLoadBalancer.java |  15 +--
 .../tubemq/server/master/balance/LoadBalancer.java |   3 -
 .../metastore/BdbMetaStoreServiceImpl.java         |  30 +++---
 19 files changed, 151 insertions(+), 166 deletions(-)
 rename inlong-tubemq/tubemq-server/src/main/java/org/apache/inlong/tubemq/server/{common => broker/offset}/offsetstorage/OffsetStorage.java (95%)
 rename inlong-tubemq/tubemq-server/src/main/java/org/apache/inlong/tubemq/server/{common => broker/offset}/offsetstorage/OffsetStorageInfo.java (98%)
 rename inlong-tubemq/tubemq-server/src/main/java/org/apache/inlong/tubemq/server/{common => broker/offset}/offsetstorage/ZkOffsetStorage.java (85%)
 rename inlong-tubemq/tubemq-server/src/main/java/org/apache/inlong/tubemq/server/common/{offsetstorage => }/zookeeper/Abortable.java (94%)
 rename inlong-tubemq/tubemq-server/src/main/java/org/apache/inlong/tubemq/server/common/{offsetstorage => }/zookeeper/RecoverableZooKeeper.java (99%)
 rename inlong-tubemq/tubemq-server/src/main/java/org/apache/inlong/tubemq/server/common/{offsetstorage => }/zookeeper/RetryCounter.java (96%)
 rename inlong-tubemq/tubemq-server/src/main/java/org/apache/inlong/tubemq/server/common/{offsetstorage => }/zookeeper/RetryCounterFactory.java (95%)
 rename inlong-tubemq/tubemq-server/src/main/java/org/apache/inlong/tubemq/server/common/{offsetstorage => }/zookeeper/ZKUtil.java (83%)
 rename inlong-tubemq/tubemq-server/src/main/java/org/apache/inlong/tubemq/server/common/{offsetstorage => }/zookeeper/ZooKeeperConnectionException.java (95%)
 rename inlong-tubemq/tubemq-server/src/main/java/org/apache/inlong/tubemq/server/common/{offsetstorage => }/zookeeper/ZooKeeperListener.java (97%)
 rename inlong-tubemq/tubemq-server/src/main/java/org/apache/inlong/tubemq/server/common/{offsetstorage => }/zookeeper/ZooKeeperWatcher.java (99%)