This is an automated email from the ASF dual-hosted git repository.
lhotari pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar.git
The following commit(s) were added to refs/heads/master by this push:
new 388dcd1e870 [improve][test] Fix deprecation and unchecked compilation
warnings in test code (#25447)
388dcd1e870 is described below
commit 388dcd1e8705f3e3fae7a8807eda15cf2221b80a
Author: Matteo Merli <[email protected]>
AuthorDate: Tue Mar 31 13:32:35 2026 -0700
[improve][test] Fix deprecation and unchecked compilation warnings in test
code (#25447)
---
.../mledger/impl/cache/PendingReadsManagerTest.java | 2 ++
.../java/org/apache/pulsar/broker/EmbeddedPulsarCluster.java | 2 --
.../extensions/AntiAffinityNamespaceGroupExtensionTest.java | 2 +-
.../broker/service/OneWayReplicatorDeduplicationTest.java | 1 +
.../broker/service/persistent/PersistentTopicTest.java | 1 +
.../apache/pulsar/client/api/BrokerServiceLookupTest.java | 1 +
.../java/org/apache/pulsar/client/api/InterceptorsTest.java | 1 +
.../apache/pulsar/client/api/KeySharedSubscriptionTest.java | 1 +
...onsumerTopicWatcherBackPressureMultipleConsumersTest.java | 4 +---
.../apache/pulsar/client/api/SimpleProducerConsumerTest.java | 3 +--
.../java/org/apache/pulsar/client/api/SimpleSchemaTest.java | 2 ++
.../org/apache/pulsar/client/impl/ConnectionPoolTest.java | 1 +
.../apache/pulsar/client/impl/ProducerMemoryLeakTest.java | 1 +
.../pulsar/compaction/TopicCompactionStrategyTest.java | 3 +--
.../org/apache/pulsar/admin/cli/PulsarAdminToolTest.java | 2 +-
.../apache/pulsar/client/impl/ConsumerBuilderImplTest.java | 2 +-
.../java/org/apache/pulsar/client/impl/ConsumerImplTest.java | 3 ++-
.../pulsar/client/impl/PartitionedProducerImplTest.java | 2 +-
.../apache/pulsar/client/impl/schema/BooleanSchemaTest.java | 12 ++++++------
.../pulsar/functions/instance/JavaInstanceRunnableTest.java | 1 +
.../functions/runtime/kubernetes/KubernetesRuntimeTest.java | 1 +
.../functions/worker/FunctionMetaDataTopicTailerTest.java | 1 +
.../java/org/apache/pulsar/io/common/IOConfigUtilsTest.java | 3 +++
.../auth/token/TokenAuthWithPublicPrivateKeys.java | 2 ++
.../tests/integration/cli/FileSystemPackagesCliTest.java | 2 ++
.../apache/pulsar/tests/integration/cli/PackagesCliTest.java | 2 ++
.../pulsar/tests/integration/cli/PulsarVersionTest.java | 1 +
.../integration/containers/PulsarInitMetadataContainer.java | 1 +
.../tests/integration/io/PulsarGenericObjectSinkTest.java | 1 +
.../tests/integration/metrics/OpenTelemetrySanityTest.java | 3 +++
.../pulsar/tests/integration/offload/TestBaseOffload.java | 3 +++
.../pulsar/tests/integration/topologies/PulsarCluster.java | 1 +
.../apache/pulsar/tests/integration/utils/DockerUtils.java | 1 +
.../pulsar/tests/integration/SimpleProducerConsumerTest.java | 1 +
34 files changed, 50 insertions(+), 20 deletions(-)
diff --git
a/managed-ledger/src/test/java/org/apache/bookkeeper/mledger/impl/cache/PendingReadsManagerTest.java
b/managed-ledger/src/test/java/org/apache/bookkeeper/mledger/impl/cache/PendingReadsManagerTest.java
index 9c6c79eb95b..99762235ca6 100644
---
a/managed-ledger/src/test/java/org/apache/bookkeeper/mledger/impl/cache/PendingReadsManagerTest.java
+++
b/managed-ledger/src/test/java/org/apache/bookkeeper/mledger/impl/cache/PendingReadsManagerTest.java
@@ -47,6 +47,7 @@ import java.util.function.BiFunction;
import java.util.function.IntSupplier;
import java.util.stream.Collectors;
import lombok.Data;
+import lombok.EqualsAndHashCode;
import lombok.extern.slf4j.Slf4j;
import org.apache.bookkeeper.client.api.ReadHandle;
import org.apache.bookkeeper.mledger.AsyncCallbacks;
@@ -132,6 +133,7 @@ public class PendingReadsManagerTest {
@Data
+ @EqualsAndHashCode(callSuper = false)
private static class CapturingReadEntriesCallback extends
CompletableFuture<Void>
implements AsyncCallbacks.ReadEntriesCallback {
List<Position> entries;
diff --git
a/pulsar-broker/src/test/java/org/apache/pulsar/broker/EmbeddedPulsarCluster.java
b/pulsar-broker/src/test/java/org/apache/pulsar/broker/EmbeddedPulsarCluster.java
index f66f5d86335..b5fac356fc6 100644
---
a/pulsar-broker/src/test/java/org/apache/pulsar/broker/EmbeddedPulsarCluster.java
+++
b/pulsar-broker/src/test/java/org/apache/pulsar/broker/EmbeddedPulsarCluster.java
@@ -35,10 +35,8 @@ public class EmbeddedPulsarCluster implements AutoCloseable {
private static final String CLUSTER_NAME = "embedded";
- @Builder.Default
private int numBrokers = 1;
- @Builder.Default
private int numBookies = 1;
private final String metadataStoreUrl;
diff --git
a/pulsar-broker/src/test/java/org/apache/pulsar/broker/loadbalance/extensions/AntiAffinityNamespaceGroupExtensionTest.java
b/pulsar-broker/src/test/java/org/apache/pulsar/broker/loadbalance/extensions/AntiAffinityNamespaceGroupExtensionTest.java
index 78e991eef04..fe3d7b3a2e6 100644
---
a/pulsar-broker/src/test/java/org/apache/pulsar/broker/loadbalance/extensions/AntiAffinityNamespaceGroupExtensionTest.java
+++
b/pulsar-broker/src/test/java/org/apache/pulsar/broker/loadbalance/extensions/AntiAffinityNamespaceGroupExtensionTest.java
@@ -89,8 +89,8 @@ public class AntiAffinityNamespaceGroupExtensionTest extends
AntiAffinityNamespa
// No-op
}
+ @SuppressWarnings("unchecked")
protected boolean isLoadManagerUpdatedDomainCache(Object loadManager)
throws Exception {
- @SuppressWarnings("unchecked")
var antiAffinityGroupPolicyHelper =
(AntiAffinityGroupPolicyHelper)
FieldUtils.readDeclaredField(
diff --git
a/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/OneWayReplicatorDeduplicationTest.java
b/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/OneWayReplicatorDeduplicationTest.java
index c6db10f43c1..b63f15f9ac8 100644
---
a/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/OneWayReplicatorDeduplicationTest.java
+++
b/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/OneWayReplicatorDeduplicationTest.java
@@ -857,6 +857,7 @@ public class OneWayReplicatorDeduplicationTest extends
OneWayReplicatorTestBase
}
@Test(timeOut = 360 * 1000, dataProvider = "enabledDeduplication")
+ @SuppressWarnings("unchecked")
public void testReplicationLoadSchemaTimeout(boolean enabledDeduplication)
throws Exception {
waitInternalClientCreated();
diff --git
a/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/persistent/PersistentTopicTest.java
b/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/persistent/PersistentTopicTest.java
index e2e30c5e65d..f69c1d66aec 100644
---
a/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/persistent/PersistentTopicTest.java
+++
b/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/persistent/PersistentTopicTest.java
@@ -304,6 +304,7 @@ public class PersistentTopicTest extends BrokerTestBase {
}
@Test
+ @SuppressWarnings("unchecked")
public void testPersistentPartitionedTopicUnload() throws Exception {
final String topicName = "persistent://prop/ns/failedUnload";
final String ns = "prop/ns";
diff --git
a/pulsar-broker/src/test/java/org/apache/pulsar/client/api/BrokerServiceLookupTest.java
b/pulsar-broker/src/test/java/org/apache/pulsar/client/api/BrokerServiceLookupTest.java
index 12d32482330..280d692b50b 100644
---
a/pulsar-broker/src/test/java/org/apache/pulsar/client/api/BrokerServiceLookupTest.java
+++
b/pulsar-broker/src/test/java/org/apache/pulsar/client/api/BrokerServiceLookupTest.java
@@ -976,6 +976,7 @@ public class BrokerServiceLookupTest extends
ProducerConsumerBase implements ITe
}
@Test
+ @SuppressWarnings("unchecked")
public void testMergeLookupRequests() throws Exception {
// Assert the lookup service is a "BinaryProtoLookupService".
final PulsarClientImpl pulsarClientImpl = (PulsarClientImpl)
pulsarClient;
diff --git
a/pulsar-broker/src/test/java/org/apache/pulsar/client/api/InterceptorsTest.java
b/pulsar-broker/src/test/java/org/apache/pulsar/client/api/InterceptorsTest.java
index baee49f1884..3690ad80f3f 100644
---
a/pulsar-broker/src/test/java/org/apache/pulsar/client/api/InterceptorsTest.java
+++
b/pulsar-broker/src/test/java/org/apache/pulsar/client/api/InterceptorsTest.java
@@ -47,6 +47,7 @@ import org.testng.annotations.DataProvider;
import org.testng.annotations.Test;
@Test(groups = "broker-api")
+@SuppressWarnings("unchecked")
public class InterceptorsTest extends SharedPulsarBaseTest {
private static final Logger log =
LoggerFactory.getLogger(InterceptorsTest.class);
diff --git
a/pulsar-broker/src/test/java/org/apache/pulsar/client/api/KeySharedSubscriptionTest.java
b/pulsar-broker/src/test/java/org/apache/pulsar/client/api/KeySharedSubscriptionTest.java
index 8496bed6d96..6434a18b393 100644
---
a/pulsar-broker/src/test/java/org/apache/pulsar/client/api/KeySharedSubscriptionTest.java
+++
b/pulsar-broker/src/test/java/org/apache/pulsar/client/api/KeySharedSubscriptionTest.java
@@ -2047,6 +2047,7 @@ public class KeySharedSubscriptionTest extends
ProducerConsumerBase {
* - at last, all messages will be received.
*/
@Test(timeOut = 180 * 1000, dataProvider = "allowKeySharedOutOfOrder") //
the test will be finished in 60s.
+ @SuppressWarnings("unchecked")
public void
testRecentJoinedPosWillNotStuckOtherConsumer(KeySharedImplementationType impl,
boolean
allowKeySharedOutOfOrder) throws Exception {
final int messagesSentPerTime = 100;
diff --git
a/pulsar-broker/src/test/java/org/apache/pulsar/client/api/PatternConsumerTopicWatcherBackPressureMultipleConsumersTest.java
b/pulsar-broker/src/test/java/org/apache/pulsar/client/api/PatternConsumerTopicWatcherBackPressureMultipleConsumersTest.java
index 9690e9887ad..eeabe37c660 100644
---
a/pulsar-broker/src/test/java/org/apache/pulsar/client/api/PatternConsumerTopicWatcherBackPressureMultipleConsumersTest.java
+++
b/pulsar-broker/src/test/java/org/apache/pulsar/client/api/PatternConsumerTopicWatcherBackPressureMultipleConsumersTest.java
@@ -71,9 +71,8 @@ public class
PatternConsumerTopicWatcherBackPressureMultipleConsumersTest extend
protected void cleanup() throws Exception {
super.internalCleanup();
}
- @SuppressWarnings("deprecation")
-
@Test(timeOut = 60 * 1000)
+ @SuppressWarnings({"deprecation", "unchecked"})
public void
testPatternConsumerWithLargeAmountOfConcurrentClientConnections()
throws PulsarAdminException, InterruptedException, IOException,
ExecutionException, TimeoutException {
// create a new namespace for this test
@@ -84,7 +83,6 @@ public class
PatternConsumerTopicWatcherBackPressureMultipleConsumersTest extend
final int numberOfClients = 100;
// create a long topic name to consume more memory per topic
- @SuppressWarnings("unchecked")
final String topicNamePrefix = "persistent://" + namespace + "/" +
StringUtils.repeat('a', 512) + "-";
// number of topics to create
final int topicCount = 300;
diff --git
a/pulsar-broker/src/test/java/org/apache/pulsar/client/api/SimpleProducerConsumerTest.java
b/pulsar-broker/src/test/java/org/apache/pulsar/client/api/SimpleProducerConsumerTest.java
index 47339bc5fe6..ccd7efc4322 100644
---
a/pulsar-broker/src/test/java/org/apache/pulsar/client/api/SimpleProducerConsumerTest.java
+++
b/pulsar-broker/src/test/java/org/apache/pulsar/client/api/SimpleProducerConsumerTest.java
@@ -4968,9 +4968,8 @@ public class SimpleProducerConsumerTest extends
ProducerConsumerBase {
{false}
};
}
- @SuppressWarnings("deprecation")
-
@Test(dataProvider = "enableBatchSend")
+ @SuppressWarnings({"deprecation", "unchecked"})
public void testPublishWithCreateMessageManually(boolean enableBatchSend)
throws Exception {
final int messageCount = 10;
final List<MessageImpl> messageArrayBeforeSend =
Collections.synchronizedList(new ArrayList<>());
diff --git
a/pulsar-broker/src/test/java/org/apache/pulsar/client/api/SimpleSchemaTest.java
b/pulsar-broker/src/test/java/org/apache/pulsar/client/api/SimpleSchemaTest.java
index f3e4ea3c585..51776748c27 100644
---
a/pulsar-broker/src/test/java/org/apache/pulsar/client/api/SimpleSchemaTest.java
+++
b/pulsar-broker/src/test/java/org/apache/pulsar/client/api/SimpleSchemaTest.java
@@ -356,6 +356,7 @@ public class SimpleSchemaTest extends ProducerConsumerBase {
}
@Test
+ @SuppressWarnings("unchecked")
public void testProducerConnectStateWhenRegisteringSchema() throws
Exception {
final String topic =
BrokerTestUtil.newUniqueName(NAMESPACE_ALWAYS_COMPATIBLE + "/tp");
final String subscription = "s1";
@@ -393,6 +394,7 @@ public class SimpleSchemaTest extends ProducerConsumerBase {
}
@Test
+ @SuppressWarnings("unchecked")
public void testNoMemoryLeakIfSchemaIncompatible() throws Exception {
final String topic =
BrokerTestUtil.newUniqueName(NAMESPACE_NEVER_COMPATIBLE + "/tp");
final String subscription = "s1";
diff --git
a/pulsar-broker/src/test/java/org/apache/pulsar/client/impl/ConnectionPoolTest.java
b/pulsar-broker/src/test/java/org/apache/pulsar/client/impl/ConnectionPoolTest.java
index d7d1fee31ee..e8d30c90aa3 100644
---
a/pulsar-broker/src/test/java/org/apache/pulsar/client/impl/ConnectionPoolTest.java
+++
b/pulsar-broker/src/test/java/org/apache/pulsar/client/impl/ConnectionPoolTest.java
@@ -211,6 +211,7 @@ public class ConnectionPoolTest extends
MockedPulsarServiceBaseTest {
@Test
+ @SuppressWarnings("unchecked")
public void testSetProxyToTargetBrokerAddress() throws Exception {
ClientConfigurationData conf = new ClientConfigurationData();
conf.setConnectionsPerBroker(1);
diff --git
a/pulsar-broker/src/test/java/org/apache/pulsar/client/impl/ProducerMemoryLeakTest.java
b/pulsar-broker/src/test/java/org/apache/pulsar/client/impl/ProducerMemoryLeakTest.java
index affb7bc5998..8f857c952d8 100644
---
a/pulsar-broker/src/test/java/org/apache/pulsar/client/impl/ProducerMemoryLeakTest.java
+++
b/pulsar-broker/src/test/java/org/apache/pulsar/client/impl/ProducerMemoryLeakTest.java
@@ -317,6 +317,7 @@ public class ProducerMemoryLeakTest extends
SharedPulsarBaseTest {
}
@Test(dataProvider = "failedInterceptAt")
+ @SuppressWarnings("unchecked")
public void testInterceptorError(String method) throws Exception {
final String topicName = newTopicName();
admin.topics().createNonPartitionedTopic(topicName);
diff --git
a/pulsar-broker/src/test/java/org/apache/pulsar/compaction/TopicCompactionStrategyTest.java
b/pulsar-broker/src/test/java/org/apache/pulsar/compaction/TopicCompactionStrategyTest.java
index eee8498ed17..770ce140460 100644
---
a/pulsar-broker/src/test/java/org/apache/pulsar/compaction/TopicCompactionStrategyTest.java
+++
b/pulsar-broker/src/test/java/org/apache/pulsar/compaction/TopicCompactionStrategyTest.java
@@ -28,8 +28,7 @@ public class TopicCompactionStrategyTest {
public static class DummyTopicCompactionStrategy implements
TopicCompactionStrategy<byte[]> {
@Override
- @SuppressWarnings("unchecked")
- public Schema getSchema() {
+ public Schema<byte[]> getSchema() {
return Schema.BYTES;
}
diff --git
a/pulsar-client-tools-test/src/test/java/org/apache/pulsar/admin/cli/PulsarAdminToolTest.java
b/pulsar-client-tools-test/src/test/java/org/apache/pulsar/admin/cli/PulsarAdminToolTest.java
index f39b4f3e21e..82132078cd7 100644
---
a/pulsar-client-tools-test/src/test/java/org/apache/pulsar/admin/cli/PulsarAdminToolTest.java
+++
b/pulsar-client-tools-test/src/test/java/org/apache/pulsar/admin/cli/PulsarAdminToolTest.java
@@ -1589,7 +1589,7 @@ public class PulsarAdminToolTest {
}
- @SuppressWarnings("deprecation")
+ @SuppressWarnings({"deprecation", "unchecked"})
@Test
public void topics() throws Exception {
PulsarAdmin admin = Mockito.mock(PulsarAdmin.class);
diff --git
a/pulsar-client/src/test/java/org/apache/pulsar/client/impl/ConsumerBuilderImplTest.java
b/pulsar-client/src/test/java/org/apache/pulsar/client/impl/ConsumerBuilderImplTest.java
index f357aa31630..186d6ad99bb 100644
---
a/pulsar-client/src/test/java/org/apache/pulsar/client/impl/ConsumerBuilderImplTest.java
+++
b/pulsar-client/src/test/java/org/apache/pulsar/client/impl/ConsumerBuilderImplTest.java
@@ -121,7 +121,7 @@ public class ConsumerBuilderImplTest {
@Test(expectedExceptions = IllegalArgumentException.class)
public void testConsumerBuilderImplWhenTopicNamesVarargsIsNull() {
- consumerBuilderImpl.topic(null);
+ consumerBuilderImpl.topic((String[]) null);
}
@Test(expectedExceptions = IllegalArgumentException.class)
diff --git
a/pulsar-client/src/test/java/org/apache/pulsar/client/impl/ConsumerImplTest.java
b/pulsar-client/src/test/java/org/apache/pulsar/client/impl/ConsumerImplTest.java
index 6db122db23d..27ba9f4f2ed 100644
---
a/pulsar-client/src/test/java/org/apache/pulsar/client/impl/ConsumerImplTest.java
+++
b/pulsar-client/src/test/java/org/apache/pulsar/client/impl/ConsumerImplTest.java
@@ -70,7 +70,7 @@ public class ConsumerImplTest {
createConsumer(consumerConf);
}
- @SuppressWarnings("rawtypes")
+ @SuppressWarnings({"rawtypes", "unchecked"})
private void createConsumer(ConsumerConfigurationData consumerConf) {
executorProvider = new ExecutorProvider(1, "ConsumerImplTest");
internalExecutor = Executors.newSingleThreadScheduledExecutor();
@@ -148,6 +148,7 @@ public class ConsumerImplTest {
}
@Test(invocationTimeOut = 1000)
+ @SuppressWarnings("unchecked")
public void
testNotifyPendingReceivedCallback_InterceptorsWorksWithPrefetchDisabled() {
CompletableFuture<Message<byte[]>> receiveFuture = new
CompletableFuture<>();
@SuppressWarnings("rawtypes")
diff --git
a/pulsar-client/src/test/java/org/apache/pulsar/client/impl/PartitionedProducerImplTest.java
b/pulsar-client/src/test/java/org/apache/pulsar/client/impl/PartitionedProducerImplTest.java
index 5df1eb68509..f2acdfa3f17 100644
---
a/pulsar-client/src/test/java/org/apache/pulsar/client/impl/PartitionedProducerImplTest.java
+++
b/pulsar-client/src/test/java/org/apache/pulsar/client/impl/PartitionedProducerImplTest.java
@@ -73,7 +73,7 @@ public class PartitionedProducerImplTest {
private CompletableFuture producerCreatedFuture;
@BeforeMethod(alwaysRun = true)
- @SuppressWarnings("rawtypes")
+ @SuppressWarnings({"rawtypes", "unchecked"})
public void setup() {
client = mock(PulsarClientImpl.class);
ConnectionPool connectionPool = mock(ConnectionPool.class);
diff --git
a/pulsar-client/src/test/java/org/apache/pulsar/client/impl/schema/BooleanSchemaTest.java
b/pulsar-client/src/test/java/org/apache/pulsar/client/impl/schema/BooleanSchemaTest.java
index 750e308151d..84cce1f7ec6 100644
---
a/pulsar-client/src/test/java/org/apache/pulsar/client/impl/schema/BooleanSchemaTest.java
+++
b/pulsar-client/src/test/java/org/apache/pulsar/client/impl/schema/BooleanSchemaTest.java
@@ -41,8 +41,8 @@ public class BooleanSchemaTest {
@Test
public void testSchemaEncodeDecodeFidelity() {
BooleanSchema schema = BooleanSchema.of();
- Assert.assertEquals(new Boolean(true),
schema.decode(schema.encode(true)));
- Assert.assertEquals(new Boolean(false),
schema.decode(schema.encode(false)));
+ Assert.assertEquals(Boolean.valueOf(true),
schema.decode(schema.encode(true)));
+ Assert.assertEquals(Boolean.valueOf(false),
schema.decode(schema.encode(false)));
}
@Test
@@ -54,16 +54,16 @@ public class BooleanSchemaTest {
0
};
BooleanSchema schema = BooleanSchema.of();
- Assert.assertEquals(new Boolean(true), schema.decode(trueBytes));
- Assert.assertEquals(new Boolean(false), schema.decode(falseBytes));
+ Assert.assertEquals(Boolean.valueOf(true), schema.decode(trueBytes));
+ Assert.assertEquals(Boolean.valueOf(false), schema.decode(falseBytes));
ByteBuf byteBuf = ByteBufAllocator.DEFAULT.buffer(1);
byteBuf.writeBytes(trueBytes);
- Assert.assertEquals(new Boolean(true), schema.decode(byteBuf));
+ Assert.assertEquals(Boolean.valueOf(true), schema.decode(byteBuf));
byteBuf.writerIndex(0);
byteBuf.writeBytes(falseBytes);
- Assert.assertEquals(new Boolean(false), schema.decode(byteBuf));
+ Assert.assertEquals(Boolean.valueOf(false), schema.decode(byteBuf));
}
@Test
diff --git
a/pulsar-functions/instance/src/test/java/org/apache/pulsar/functions/instance/JavaInstanceRunnableTest.java
b/pulsar-functions/instance/src/test/java/org/apache/pulsar/functions/instance/JavaInstanceRunnableTest.java
index c66910fd0f0..0e76761fb47 100644
---
a/pulsar-functions/instance/src/test/java/org/apache/pulsar/functions/instance/JavaInstanceRunnableTest.java
+++
b/pulsar-functions/instance/src/test/java/org/apache/pulsar/functions/instance/JavaInstanceRunnableTest.java
@@ -197,6 +197,7 @@ public class JavaInstanceRunnableTest {
}
@Test
+ @SuppressWarnings("unchecked")
public void testFunctionResultNull() throws Exception {
JavaExecutionResult javaExecutionResult = new JavaExecutionResult();
diff --git
a/pulsar-functions/runtime/src/test/java/org/apache/pulsar/functions/runtime/kubernetes/KubernetesRuntimeTest.java
b/pulsar-functions/runtime/src/test/java/org/apache/pulsar/functions/runtime/kubernetes/KubernetesRuntimeTest.java
index ed12fda0ce1..252906557b6 100644
---
a/pulsar-functions/runtime/src/test/java/org/apache/pulsar/functions/runtime/kubernetes/KubernetesRuntimeTest.java
+++
b/pulsar-functions/runtime/src/test/java/org/apache/pulsar/functions/runtime/kubernetes/KubernetesRuntimeTest.java
@@ -1011,6 +1011,7 @@ public class KubernetesRuntimeTest {
verifyGolangInstance(config);
}
+ @SuppressWarnings("deprecation")
private void verifyGolangInstance(InstanceConfig config) throws Exception {
KubernetesRuntime container = factory.createContainer(config,
userJarFile, userJarFile,
null, null, 30L);
diff --git
a/pulsar-functions/worker/src/test/java/org/apache/pulsar/functions/worker/FunctionMetaDataTopicTailerTest.java
b/pulsar-functions/worker/src/test/java/org/apache/pulsar/functions/worker/FunctionMetaDataTopicTailerTest.java
index b3a6594ac5b..6decd0271ec 100644
---
a/pulsar-functions/worker/src/test/java/org/apache/pulsar/functions/worker/FunctionMetaDataTopicTailerTest.java
+++
b/pulsar-functions/worker/src/test/java/org/apache/pulsar/functions/worker/FunctionMetaDataTopicTailerTest.java
@@ -51,6 +51,7 @@ public class FunctionMetaDataTopicTailerTest {
private FunctionMetaDataTopicTailer fsc;
@BeforeMethod(alwaysRun = true)
+ @SuppressWarnings("unchecked")
public void before() throws Exception {
this.reader = mock(Reader.class);
this.readerBuilder = mock(ReaderBuilder.class);
diff --git
a/pulsar-io/common/src/test/java/org/apache/pulsar/io/common/IOConfigUtilsTest.java
b/pulsar-io/common/src/test/java/org/apache/pulsar/io/common/IOConfigUtilsTest.java
index b9c09c67888..37986b0259b 100644
---
a/pulsar-io/common/src/test/java/org/apache/pulsar/io/common/IOConfigUtilsTest.java
+++
b/pulsar-io/common/src/test/java/org/apache/pulsar/io/common/IOConfigUtilsTest.java
@@ -24,6 +24,7 @@ import java.util.HashMap;
import java.util.Map;
import java.util.concurrent.CompletableFuture;
import lombok.Data;
+import lombok.EqualsAndHashCode;
import lombok.extern.slf4j.Slf4j;
import org.apache.pulsar.client.api.ConsumerBuilder;
import org.apache.pulsar.client.api.PulsarClient;
@@ -149,6 +150,7 @@ public class IOConfigUtilsTest {
}
@Data
+ @EqualsAndHashCode(callSuper = false)
static class DerivedConfig extends TestConfig {
@FieldDoc(
required = true,
@@ -160,6 +162,7 @@ public class IOConfigUtilsTest {
}
@Data
+ @EqualsAndHashCode(callSuper = false)
static class DerivedDerivedConfig extends DerivedConfig {
@FieldDoc(
required = true,
diff --git
a/tests/integration/src/test/java/org/apache/pulsar/tests/integration/auth/token/TokenAuthWithPublicPrivateKeys.java
b/tests/integration/src/test/java/org/apache/pulsar/tests/integration/auth/token/TokenAuthWithPublicPrivateKeys.java
index 1ccdf901944..a7ec0983aad 100644
---
a/tests/integration/src/test/java/org/apache/pulsar/tests/integration/auth/token/TokenAuthWithPublicPrivateKeys.java
+++
b/tests/integration/src/test/java/org/apache/pulsar/tests/integration/auth/token/TokenAuthWithPublicPrivateKeys.java
@@ -74,12 +74,14 @@ public class TokenAuthWithPublicPrivateKeys extends
PulsarTokenAuthenticationBas
log.info("Created proxy token: {}", proxyAuthToken);
}
+ @SuppressWarnings("deprecation")
@Override
protected void configureBroker(BrokerContainer brokerContainer) throws
Exception {
brokerContainer.withFileSystemBind(publicKeyFile.toString(),
PUBLIC_KEY_PATH_INSIDE_CONTAINER);
brokerContainer.withEnv("tokenPublicKey", "file://" +
PUBLIC_KEY_PATH_INSIDE_CONTAINER);
}
+ @SuppressWarnings("deprecation")
@Override
protected void configureProxy(ProxyContainer proxyContainer) throws
Exception {
proxyContainer.withFileSystemBind(publicKeyFile.toString(),
PUBLIC_KEY_PATH_INSIDE_CONTAINER);
diff --git
a/tests/integration/src/test/java/org/apache/pulsar/tests/integration/cli/FileSystemPackagesCliTest.java
b/tests/integration/src/test/java/org/apache/pulsar/tests/integration/cli/FileSystemPackagesCliTest.java
index 59b8a6c4008..c0c67a1e8e3 100644
---
a/tests/integration/src/test/java/org/apache/pulsar/tests/integration/cli/FileSystemPackagesCliTest.java
+++
b/tests/integration/src/test/java/org/apache/pulsar/tests/integration/cli/FileSystemPackagesCliTest.java
@@ -38,6 +38,7 @@ public class FileSystemPackagesCliTest extends
TestRetrySupport {
private static final String clusterNamePrefix =
"file-system-packages-service";
private PulsarCluster pulsarCluster;
+ @SuppressWarnings("deprecation")
@BeforeClass(alwaysRun = true)
public final void setup() throws Exception {
incrementSetupNumber();
@@ -66,6 +67,7 @@ public class FileSystemPackagesCliTest extends
TestRetrySupport {
return envs;
}
+ @SuppressWarnings("deprecation")
@Test(timeOut = 60000 * 8)
public void
testPackagesOperationsWithUploadingPackagesUsingFileSystemStorageProvider()
throws Exception {
BrokerContainer container = pulsarCluster.getBroker(0);
diff --git
a/tests/integration/src/test/java/org/apache/pulsar/tests/integration/cli/PackagesCliTest.java
b/tests/integration/src/test/java/org/apache/pulsar/tests/integration/cli/PackagesCliTest.java
index 440ab2fb3bf..fd979c112fe 100644
---
a/tests/integration/src/test/java/org/apache/pulsar/tests/integration/cli/PackagesCliTest.java
+++
b/tests/integration/src/test/java/org/apache/pulsar/tests/integration/cli/PackagesCliTest.java
@@ -39,6 +39,7 @@ public class PackagesCliTest extends TestRetrySupport {
private static final String clusterNamePrefix = "packages-service";
private PulsarCluster pulsarCluster;
+ @SuppressWarnings("deprecation")
@BeforeClass(alwaysRun = true)
public final void setup() throws Exception {
incrementSetupNumber();
@@ -82,6 +83,7 @@ public class PackagesCliTest extends TestRetrySupport {
}
}
+ @SuppressWarnings("deprecation")
@Test(timeOut = 60000 * 8)
public void testPackagesOperationsWithUploadingPackages() throws Exception
{
String testPackageName = "function://public/default/test@v1";
diff --git
a/tests/integration/src/test/java/org/apache/pulsar/tests/integration/cli/PulsarVersionTest.java
b/tests/integration/src/test/java/org/apache/pulsar/tests/integration/cli/PulsarVersionTest.java
index 711dd3b9c00..e3354042146 100644
---
a/tests/integration/src/test/java/org/apache/pulsar/tests/integration/cli/PulsarVersionTest.java
+++
b/tests/integration/src/test/java/org/apache/pulsar/tests/integration/cli/PulsarVersionTest.java
@@ -36,6 +36,7 @@ public class PulsarVersionTest extends TestRetrySupport {
private static final String clusterNamePrefix = "pulsar-version";
private PulsarCluster pulsarCluster;
+ @SuppressWarnings("deprecation")
@Override
@BeforeClass(alwaysRun = true)
public final void setup() throws Exception {
diff --git
a/tests/integration/src/test/java/org/apache/pulsar/tests/integration/containers/PulsarInitMetadataContainer.java
b/tests/integration/src/test/java/org/apache/pulsar/tests/integration/containers/PulsarInitMetadataContainer.java
index 68757d9fece..bb26cc7a628 100644
---
a/tests/integration/src/test/java/org/apache/pulsar/tests/integration/containers/PulsarInitMetadataContainer.java
+++
b/tests/integration/src/test/java/org/apache/pulsar/tests/integration/containers/PulsarInitMetadataContainer.java
@@ -37,6 +37,7 @@ public class PulsarInitMetadataContainer extends
GenericContainer<PulsarInitMeta
private final String configurationMetadataStoreUrl;
private final String brokerHostname;
+ @SuppressWarnings("deprecation")
public PulsarInitMetadataContainer(Network network,
String clusterName,
String metadataStoreUrl,
diff --git
a/tests/integration/src/test/java/org/apache/pulsar/tests/integration/io/PulsarGenericObjectSinkTest.java
b/tests/integration/src/test/java/org/apache/pulsar/tests/integration/io/PulsarGenericObjectSinkTest.java
index 25f9aa80490..cf9f2d230ee 100644
---
a/tests/integration/src/test/java/org/apache/pulsar/tests/integration/io/PulsarGenericObjectSinkTest.java
+++
b/tests/integration/src/test/java/org/apache/pulsar/tests/integration/io/PulsarGenericObjectSinkTest.java
@@ -87,6 +87,7 @@ public class PulsarGenericObjectSinkTest extends
PulsarStandaloneTestSuite {
}
@Test(groups = {"sink"})
+ @SuppressWarnings("unchecked")
public void testGenericObjectSink() throws Exception {
@Cleanup PulsarClient client = PulsarClient.builder()
diff --git
a/tests/integration/src/test/java/org/apache/pulsar/tests/integration/metrics/OpenTelemetrySanityTest.java
b/tests/integration/src/test/java/org/apache/pulsar/tests/integration/metrics/OpenTelemetrySanityTest.java
index 4e6847d1723..c09801c2171 100644
---
a/tests/integration/src/test/java/org/apache/pulsar/tests/integration/metrics/OpenTelemetrySanityTest.java
+++
b/tests/integration/src/test/java/org/apache/pulsar/tests/integration/metrics/OpenTelemetrySanityTest.java
@@ -45,6 +45,7 @@ public class OpenTelemetrySanityTest {
// Validate that the OpenTelemetry metrics can be exported to a remote
OpenTelemetry collector.
@Test(timeOut = 360_000)
+ @SuppressWarnings("unchecked")
public void testOpenTelemetryMetricsOtlpExport() throws Exception {
var clusterName = "testOpenTelemetryMetrics-" + UUID.randomUUID();
var openTelemetryCollectorContainer = new
OpenTelemetryCollectorContainer(clusterName);
@@ -95,6 +96,7 @@ public class OpenTelemetrySanityTest {
*
https://github.com/open-telemetry/opentelemetry-java/blob/main/sdk-extensions/autoconfigure/README.md#prometheus-exporter
*/
@Test(timeOut = 360_000)
+ @SuppressWarnings("unchecked")
public void testOpenTelemetryMetricsPrometheusExport() throws Exception {
var prometheusExporterPort = 9464;
var clusterName = "testOpenTelemetryMetrics-" + UUID.randomUUID();
@@ -158,6 +160,7 @@ public class OpenTelemetrySanityTest {
return client.getMetrics();
}
+ @SuppressWarnings("unchecked")
private static Map<String, String> getOpenTelemetryProps(String exporter,
Pair<String, String> ... extraProps) {
var defaultProps = Map.of(
"OTEL_SDK_DISABLED", "false",
diff --git
a/tests/integration/src/test/java/org/apache/pulsar/tests/integration/offload/TestBaseOffload.java
b/tests/integration/src/test/java/org/apache/pulsar/tests/integration/offload/TestBaseOffload.java
index 339660fd785..c2a98e418dc 100644
---
a/tests/integration/src/test/java/org/apache/pulsar/tests/integration/offload/TestBaseOffload.java
+++
b/tests/integration/src/test/java/org/apache/pulsar/tests/integration/offload/TestBaseOffload.java
@@ -52,6 +52,7 @@ public abstract class TestBaseOffload extends
PulsarTieredStorageTestSuite {
return entry;
}
+ @SuppressWarnings("deprecation")
protected void testPublishOffloadAndConsumeViaCLI(String serviceUrl,
String adminUrl) throws Exception {
final String tenant = "offload-test-cli-" + randomName(4);
final String namespace = tenant + "/ns1";
@@ -133,6 +134,7 @@ public abstract class TestBaseOffload extends
PulsarTieredStorageTestSuite {
}
}
+ @SuppressWarnings("deprecation")
protected void testPublishOffloadAndConsumeViaThreshold(String serviceUrl,
String adminUrl) throws Exception {
final String tenant = "offload-test-threshold-" + randomName(4);
final String namespace = tenant + "/ns1";
@@ -269,6 +271,7 @@ public abstract class TestBaseOffload extends
PulsarTieredStorageTestSuite {
}
}
+ @SuppressWarnings("deprecation")
public boolean ledgerExistsInBookKeeper(long ledgerId) throws Exception {
ClientConfiguration bkConf = new ClientConfiguration();
bkConf.setZkServers(pulsarCluster.getZKConnString());
diff --git
a/tests/integration/src/test/java/org/apache/pulsar/tests/integration/topologies/PulsarCluster.java
b/tests/integration/src/test/java/org/apache/pulsar/tests/integration/topologies/PulsarCluster.java
index 73d9076ad08..fa54a49d48b 100644
---
a/tests/integration/src/test/java/org/apache/pulsar/tests/integration/topologies/PulsarCluster.java
+++
b/tests/integration/src/test/java/org/apache/pulsar/tests/integration/topologies/PulsarCluster.java
@@ -115,6 +115,7 @@ public class PulsarCluster {
private final String metadataStoreUrl;
private final String configurationMetadataStoreUrl;
+ @SuppressWarnings("deprecation")
private PulsarCluster(PulsarClusterSpec spec, Network network, CSContainer
csContainer, boolean sharedCsContainer) {
this.spec = spec;
this.sharedCsContainer = sharedCsContainer;
diff --git
a/tests/integration/src/test/java/org/apache/pulsar/tests/integration/utils/DockerUtils.java
b/tests/integration/src/test/java/org/apache/pulsar/tests/integration/utils/DockerUtils.java
index fde3463498c..419cae3787a 100644
---
a/tests/integration/src/test/java/org/apache/pulsar/tests/integration/utils/DockerUtils.java
+++
b/tests/integration/src/test/java/org/apache/pulsar/tests/integration/utils/DockerUtils.java
@@ -148,6 +148,7 @@ public class DockerUtils {
}
}
+ @SuppressWarnings("deprecation")
public static void dumpContainerLogDirToTarget(DockerClient docker, String
containerId,
String path) {
File targetDirectory = getTargetDirectory(containerId);
diff --git
a/tests/pulsar-client-shade-test/src/test/java/org/apache/pulsar/tests/integration/SimpleProducerConsumerTest.java
b/tests/pulsar-client-shade-test/src/test/java/org/apache/pulsar/tests/integration/SimpleProducerConsumerTest.java
index e245d81c9fe..b178a638540 100644
---
a/tests/pulsar-client-shade-test/src/test/java/org/apache/pulsar/tests/integration/SimpleProducerConsumerTest.java
+++
b/tests/pulsar-client-shade-test/src/test/java/org/apache/pulsar/tests/integration/SimpleProducerConsumerTest.java
@@ -111,6 +111,7 @@ public class SimpleProducerConsumerTest extends
TestRetrySupport {
}
}
+ @SuppressWarnings("deprecation")
private PulsarClient newPulsarClient(String url, int intervalInSecs)
throws PulsarClientException {
return
PulsarClient.builder().serviceUrl(url).statsInterval(intervalInSecs,
TimeUnit.SECONDS).build();
}
