From 7ad0846694efd7e2f240226838ba4ba6721dd793 Mon Sep 17 00:00:00 2001
From: Chia-Ping Tsai <chia7712@gmail.com>
Date: Sun, 3 Nov 2024 03:05:40 +0800
Subject: [PATCH] [PARTITIONER] fix build error

---
 .../org/astraea/common/partitioner/PartitionerTest.java   | 8 --------
 1 file changed, 8 deletions(-)

diff --git a/common/src/test/java/org/astraea/common/partitioner/PartitionerTest.java b/common/src/test/java/org/astraea/common/partitioner/PartitionerTest.java
index a877df3912..10ac7ef61f 100644
--- a/common/src/test/java/org/astraea/common/partitioner/PartitionerTest.java
+++ b/common/src/test/java/org/astraea/common/partitioner/PartitionerTest.java
@@ -128,7 +128,6 @@ void multipleThreadTest(String className) throws IOException {
             .build()) {
       Runnable runnable =
           () -> {
-            Partitioner.beginInterdependent(instanceOfProducer(producer));
             var exceptPartition =
                 producerSend(producer, topicName, key, value, timestamp, header).partition();
             IntStream.range(0, 10)
@@ -140,9 +139,7 @@ void multipleThreadTest(String className) throws IOException {
                       assertEquals(timestamp, metadata.timestamp().get());
                       assertEquals(exceptPartition, metadata.partition());
                     });
-            Partitioner.endInterdependent(instanceOfProducer(producer));
           };
-      Partitioner.beginInterdependent(instanceOfProducer(producer));
 
       var fs =
           IntStream.range(0, 10)
@@ -160,7 +157,6 @@ void multipleThreadTest(String className) throws IOException {
                 assertEquals(timestamp, metadata.timestamp().get());
                 assertEquals(exceptPartition, metadata.partition());
               });
-      Partitioner.endInterdependent(instanceOfProducer(producer));
       fs.forEach(CompletableFuture::join);
     }
   }
@@ -190,7 +186,6 @@ void interdependentTest(String className) throws IOException {
                 assertEquals(topicName, metadata.topic());
                 assertEquals(timestamp, metadata.timestamp().get());
               });
-      Partitioner.beginInterdependent(instanceOfProducer(producer));
       var exceptPartition =
           producerSend(producer, topicName, key, value, timestamp, header).partition();
       IntStream.range(0, 99)
@@ -202,7 +197,6 @@ void interdependentTest(String className) throws IOException {
                 assertEquals(timestamp, metadata.timestamp().get());
                 assertEquals(exceptPartition, metadata.partition());
               });
-      Partitioner.endInterdependent(instanceOfProducer(producer));
       IntStream.range(0, 2400)
           .forEach(
               i -> {
@@ -211,7 +205,6 @@ void interdependentTest(String className) throws IOException {
                 assertEquals(topicName, metadata.topic());
                 assertEquals(timestamp, metadata.timestamp().get());
               });
-      Partitioner.beginInterdependent(instanceOfProducer(producer));
       var exceptPartitionSec =
           producerSend(producer, topicName, key, value, timestamp, header).partition();
       IntStream.range(0, 99)
@@ -223,7 +216,6 @@ void interdependentTest(String className) throws IOException {
                 assertEquals(timestamp, metadata.timestamp().get());
                 assertEquals(exceptPartitionSec, metadata.partition());
               });
-      Partitioner.endInterdependent(instanceOfProducer(producer));
     }
   }