diff --git a/distribution/server/src/assemble/LICENSE.bin.txt b/distribution/server/src/assemble/LICENSE.bin.txt index d9874a02d862b..6df601165c643 100644 --- a/distribution/server/src/assemble/LICENSE.bin.txt +++ b/distribution/server/src/assemble/LICENSE.bin.txt @@ -486,8 +486,6 @@ The Apache Software License, Version 2.0 - org.apache.curator-curator-recipes-5.1.0.jar * Apache Yetus - org.apache.yetus-audience-annotations-0.5.0.jar - * @FreeBuilder - - org.inferred-freebuilder-1.14.9.jar * Kubernetes Client - io.kubernetes-client-java-12.0.0.jar - io.kubernetes-client-java-api-12.0.0.jar diff --git a/pom.xml b/pom.xml index 2bcccd328e101..f07e6c2b487a9 100644 --- a/pom.xml +++ b/pom.xml @@ -469,6 +469,10 @@ flexible messaging model and an intuitive client API. org.codehaus.jackson jackson-mapper-asl + + org.inferred + freebuilder + diff --git a/pulsar-zookeeper-utils/pom.xml b/pulsar-zookeeper-utils/pom.xml index b7778b7ff0cdd..b2c6d5932e5ac 100644 --- a/pulsar-zookeeper-utils/pom.xml +++ b/pulsar-zookeeper-utils/pom.xml @@ -64,6 +64,10 @@ org.apache.zookeeper zookeeper + + org.inferred + freebuilder + diff --git a/pulsar-zookeeper-utils/src/main/java/org/apache/pulsar/zookeeper/ZkIsolatedBookieEnsemblePlacementPolicy.java b/pulsar-zookeeper-utils/src/main/java/org/apache/pulsar/zookeeper/ZkIsolatedBookieEnsemblePlacementPolicy.java index e7f393a8251dd..93202963adbc3 100644 --- a/pulsar-zookeeper-utils/src/main/java/org/apache/pulsar/zookeeper/ZkIsolatedBookieEnsemblePlacementPolicy.java +++ b/pulsar-zookeeper-utils/src/main/java/org/apache/pulsar/zookeeper/ZkIsolatedBookieEnsemblePlacementPolicy.java @@ -18,7 +18,10 @@ */ package org.apache.pulsar.zookeeper; +import com.fasterxml.jackson.databind.ObjectMapper; +import io.netty.util.HashedWheelTimer; import java.util.ArrayList; +import java.util.Arrays; import java.util.Collections; import java.util.HashMap; import java.util.HashSet; @@ -27,15 +30,14 @@ import java.util.Optional; import java.util.Set; import java.util.concurrent.TimeUnit; - -import com.fasterxml.jackson.core.JsonProcessingException; import org.apache.bookkeeper.client.BKException.BKNotEnoughBookiesException; import org.apache.bookkeeper.client.RackawareEnsemblePlacementPolicy; import org.apache.bookkeeper.client.RackawareEnsemblePlacementPolicyImpl; -import org.apache.bookkeeper.common.util.JsonUtil; import org.apache.bookkeeper.conf.ClientConfiguration; import org.apache.bookkeeper.feature.FeatureProvider; +import org.apache.bookkeeper.net.BookieId; import org.apache.bookkeeper.net.DNSToSwitchMapping; +import org.apache.bookkeeper.proto.BookieAddressResolver; import org.apache.bookkeeper.stats.StatsLogger; import org.apache.bookkeeper.zookeeper.ZooKeeperClient; import org.apache.commons.configuration.Configuration; @@ -44,22 +46,14 @@ import org.apache.commons.lang3.tuple.Pair; import org.apache.pulsar.common.policies.data.BookieInfo; import org.apache.pulsar.common.policies.data.BookiesRackConfiguration; +import org.apache.pulsar.common.policies.data.EnsemblePlacementPolicyConfig; import org.apache.pulsar.common.util.ObjectMapperFactory; import org.apache.pulsar.zookeeper.ZooKeeperCache.Deserializer; import org.apache.zookeeper.KeeperException; import org.apache.zookeeper.ZooKeeper; -import org.inferred.freebuilder.shaded.com.google.common.collect.Sets; import org.slf4j.Logger; import org.slf4j.LoggerFactory; -import com.fasterxml.jackson.databind.ObjectMapper; - -import io.netty.util.HashedWheelTimer; -import org.apache.bookkeeper.net.BookieId; -import org.apache.bookkeeper.proto.BookieAddressResolver; - -import org.apache.pulsar.common.policies.data.EnsemblePlacementPolicyConfig; - public class ZkIsolatedBookieEnsemblePlacementPolicy extends RackawareEnsemblePlacementPolicy implements Deserializer { private static final Logger LOG = LoggerFactory.getLogger(ZkIsolatedBookieEnsemblePlacementPolicy.class); @@ -210,10 +204,10 @@ private static Pair, Set> getIsolationGroup(EnsemblePlacemen String primaryIsolationGroupString = castToString(properties.getOrDefault(ISOLATION_BOOKIE_GROUPS, "")); String secondaryIsolationGroupString = castToString(properties.getOrDefault(SECONDARY_ISOLATION_BOOKIE_GROUPS, "")); if (!primaryIsolationGroupString.isEmpty()) { - pair.setLeft(Sets.newHashSet(primaryIsolationGroupString.split(","))); + pair.setLeft(new HashSet(Arrays.asList(primaryIsolationGroupString.split(",")))); } if (!secondaryIsolationGroupString.isEmpty()) { - pair.setRight(Sets.newHashSet(secondaryIsolationGroupString.split(","))); + pair.setRight(new HashSet(Arrays.asList(secondaryIsolationGroupString.split(",")))); } } return pair;