[PARTITIONER] fix build error

opensource4you · Nov 2, 2024 · 7ad0846 · 7ad0846
1 parent bbd2878
commit 7ad0846
Showing 1 changed file with 0 additions and 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
@@ -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));
     }
   }