Compact curator transactions in Announcer

GWphua · Nov 26, 2024 · cbea21a · cbea21a
1 parent 343950f
commit cbea21a
Showing 1 changed file with 1 addition and 5 deletions.
diff --git a/server/src/main/java/org/apache/druid/curator/announcement/Announcer.java b/server/src/main/java/org/apache/druid/curator/announcement/Announcer.java
@@ -21,10 +21,8 @@
 
 import com.google.common.annotations.VisibleForTesting;
 import org.apache.curator.framework.CuratorFramework;
-import org.apache.curator.framework.api.transaction.CuratorMultiTransaction;
 import org.apache.curator.framework.api.transaction.CuratorOp;
 import org.apache.curator.framework.recipes.cache.CuratorCache;
-import org.apache.curator.framework.recipes.cache.CuratorCacheBuilder;
 import org.apache.curator.framework.recipes.cache.CuratorCacheStorage;
 import org.apache.curator.utils.ZKPaths;
 import org.apache.druid.java.util.common.IAE;
@@ -144,8 +142,6 @@ public void stop()
       }
 
       if (!parentsIBuilt.isEmpty()) {
-        CuratorMultiTransaction transaction = curator.transaction();
-
         ArrayList<CuratorOp> operations = new ArrayList<>();
         for (String parent : parentsIBuilt) {
           try {
@@ -157,7 +153,7 @@ public void stop()
           }
         }
         try {
-          transaction.forOperations(operations);
+          curator.transaction().forOperations(operations);
         }
         catch (Exception e) {
           log.info(e, "Unable to commit transaction.");