From 36c8bdd71f31658fb720f23d903c052c9e2cb060 Mon Sep 17 00:00:00 2001 From: Lari Hotari Date: Wed, 9 Jun 2021 12:50:55 +0300 Subject: [PATCH] [Security] Exclude and remove freebuilder dependency --- .../server/src/assemble/LICENSE.bin.txt | 2 -- pom.xml | 4 ++++ pulsar-zookeeper-utils/pom.xml | 4 ++++ ...IsolatedBookieEnsemblePlacementPolicy.java | 22 +++++++------------ 4 files changed, 16 insertions(+), 16 deletions(-) diff --git a/distribution/server/src/assemble/LICENSE.bin.txt b/distribution/server/src/assemble/LICENSE.bin.txt index ea07c3c1600ef..2689c8a85bab9 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 735e28a7316d6..68089a2a1fbb8 100644 --- a/pom.xml +++ b/pom.xml @@ -470,6 +470,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;