[pulsar] branch branch-2.10 updated: Fix api not compatible cause compile failure.

[te...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

technoboy pushed a commit to branch branch-2.10
in repository https://gitbox.apache.org/repos/asf/pulsar.git


The following commit(s) were added to refs/heads/branch-2.10 by this push:
     new 6bebcabde50 Fix api not compatible cause compile failure.
6bebcabde50 is described below

commit 6bebcabde503e72d09fd88a466247be44bac17ed
Author: Jiwe Guo <te...@apache.org>
AuthorDate: Fri Dec 9 10:13:03 2022 +0800

    Fix api not compatible cause compile failure.
---
 .../org/apache/pulsar/broker/systopic/PartitionedSystemTopicTest.java  | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git a/pulsar-broker/src/test/java/org/apache/pulsar/broker/systopic/PartitionedSystemTopicTest.java b/pulsar-broker/src/test/java/org/apache/pulsar/broker/systopic/PartitionedSystemTopicTest.java
index e936b974e76..d8caccfd53d 100644
--- a/pulsar-broker/src/test/java/org/apache/pulsar/broker/systopic/PartitionedSystemTopicTest.java
+++ b/pulsar-broker/src/test/java/org/apache/pulsar/broker/systopic/PartitionedSystemTopicTest.java
@@ -18,6 +18,7 @@
  */
 package org.apache.pulsar.broker.systopic;
 
+import com.google.common.collect.Lists;
 import com.google.common.collect.Sets;
 import lombok.Cleanup;
 import org.apache.bookkeeper.mledger.LedgerOffloader;
@@ -260,7 +261,7 @@ public class PartitionedSystemTopicTest extends BrokerTestBase {
         CompletableFuture<SystemTopicClient.Writer<PulsarEvent>> writer2 = systemTopicClientForNamespace.newWriterAsync();
         CompletableFuture<Void> f1 = admin.topicPolicies().setCompactionThresholdAsync(topic, 1L);
 
-        FutureUtil.waitForAll(List.of(writer1, writer2, f1)).join();
+        FutureUtil.waitForAll(Lists.newArrayList(writer1, writer2, f1)).join();
         Assert.assertTrue(reader1.hasMoreEvents());
         Assert.assertNotNull(reader1.readNext());
         Assert.assertTrue(reader2.hasMoreEvents());