Skip to content

Commit

Permalink
apply pr suggestion
Browse files Browse the repository at this point in the history
  • Loading branch information
汪苏诚 committed Mar 26, 2024
1 parent 793cf16 commit 20ea61a
Showing 1 changed file with 1 addition and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -48,7 +48,7 @@ public void testAcknowledgeIndividualConcurrently() throws InterruptedException
@Cleanup("shutdown")
ExecutorService executorService = Executors.newCachedThreadPool(threadFactory);
for (int i = 0; i < 100; i++) {
int batchSize = RandomUtils.nextInt(1, 32);
int batchSize = 32;
BitSet bitSet = new BitSet(batchSize);
bitSet.set(0, batchSize);
AtomicInteger individualAcked = new AtomicInteger();
Expand Down

0 comments on commit 20ea61a

Please sign in to comment.