(pulsar) branch master updated: [improve][build] Suppress remaining unchecked warnings in source code (#25422)

[mm...@apache.org]

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

mmerli 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 c0c16fef47f [improve][build] Suppress remaining unchecked warnings in source code (#25422)
c0c16fef47f is described below

commit c0c16fef47fb3296ea75b874ad4f68549e45a204
Author: Matteo Merli <mm...@apache.org>
AuthorDate: Fri Mar 27 15:15:34 2026 -0700

    [improve][build] Suppress remaining unchecked warnings in source code (#25422)
---
 .../apache/pulsar/broker/service/PulsarMetadataEventSynchronizer.java | 2 ++
 .../main/java/org/apache/pulsar/client/admin/internal/TopicsImpl.java | 4 ++++
 .../instance/state/PulsarMetadataStateStoreProviderImpl.java          | 1 +
 .../src/main/java/org/apache/pulsar/io/core/AbstractPushSource.java   | 1 +
 4 files changed, 8 insertions(+)

diff --git a/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/PulsarMetadataEventSynchronizer.java b/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/PulsarMetadataEventSynchronizer.java
index 0eee0c25ff3..401aeb3b47a 100644
--- a/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/PulsarMetadataEventSynchronizer.java
+++ b/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/PulsarMetadataEventSynchronizer.java
@@ -133,6 +133,7 @@ public class PulsarMetadataEventSynchronizer implements MetadataEventSynchronize
         });
     }
 
+    @SuppressWarnings("unchecked")
     protected void startProducer() {
         if (isClosingOrClosed()) {
             log.info("[{}] Skip to start new producer because the synchronizer is closed", topicName);
@@ -179,6 +180,7 @@ public class PulsarMetadataEventSynchronizer implements MetadataEventSynchronize
         return producer;
     }
 
+    @SuppressWarnings("unchecked")
     private void startConsumer() {
         if (isClosingOrClosed()) {
             log.info("[{}] Skip to start new consumer because the synchronizer is closed", topicName);
diff --git a/pulsar-client-admin/src/main/java/org/apache/pulsar/client/admin/internal/TopicsImpl.java b/pulsar-client-admin/src/main/java/org/apache/pulsar/client/admin/internal/TopicsImpl.java
index c4db94c3195..11a25b63af9 100644
--- a/pulsar-client-admin/src/main/java/org/apache/pulsar/client/admin/internal/TopicsImpl.java
+++ b/pulsar-client-admin/src/main/java/org/apache/pulsar/client/admin/internal/TopicsImpl.java
@@ -339,6 +339,7 @@ public class TopicsImpl extends BaseResource implements Topics {
         return createPartitionedTopicAsync(topic, numPartitions, false, properties);
     }
 
+    @SuppressWarnings("unchecked")
     public CompletableFuture<Void> createPartitionedTopicAsync(
             String topic, int numPartitions, boolean createLocalTopicOnly, Map<String, String> properties) {
         checkArgument(numPartitions > 0, "Number of partitions should be more than 0");
@@ -1277,6 +1278,7 @@ public class TopicsImpl extends BaseResource implements Topics {
                 TransactionIsolationLevel.READ_UNCOMMITTED);
     }
 
+    @SuppressWarnings("unchecked")
     private List<Message<byte[]>> getMessagesFromHttpResponse(
             String topic, Response response, boolean showServerMarker,
             TransactionIsolationLevel transactionIsolationLevel) throws Exception {
@@ -1488,6 +1490,7 @@ public class TopicsImpl extends BaseResource implements Topics {
         }
     }
 
+    @SuppressWarnings("unchecked")
     private List<Message<byte[]>> getIndividualMsgsFromBatch(String topic, String msgId, byte[] data,
                                  Map<String, String> properties, MessageMetadata msgMetadataBuilder,
                                                              BrokerEntryMetadata brokerEntryMetadata) {
@@ -1583,6 +1586,7 @@ public class TopicsImpl extends BaseResource implements Topics {
         return sync(() -> analyzeSubscriptionBacklogAsync(topic, subscriptionName, startPosition, terminatePredicate));
     }
 
+    @SuppressWarnings("unchecked")
     @Override
     public CompletableFuture<AnalyzeSubscriptionBacklogResult> analyzeSubscriptionBacklogAsync(String topic,
                                                                                 String subscriptionName,
diff --git a/pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/instance/state/PulsarMetadataStateStoreProviderImpl.java b/pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/instance/state/PulsarMetadataStateStoreProviderImpl.java
index 5bffc5966b6..dd2a702e65f 100644
--- a/pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/instance/state/PulsarMetadataStateStoreProviderImpl.java
+++ b/pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/instance/state/PulsarMetadataStateStoreProviderImpl.java
@@ -25,6 +25,7 @@ import org.apache.pulsar.metadata.api.MetadataStore;
 import org.apache.pulsar.metadata.api.MetadataStoreConfig;
 import org.apache.pulsar.metadata.api.MetadataStoreFactory;
 
+@SuppressWarnings("unchecked")
 public class PulsarMetadataStateStoreProviderImpl implements StateStoreProvider {
 
     private static final String METADATA_URL = "METADATA_URL";
diff --git a/pulsar-io/core/src/main/java/org/apache/pulsar/io/core/AbstractPushSource.java b/pulsar-io/core/src/main/java/org/apache/pulsar/io/core/AbstractPushSource.java
index 185d1cebfbc..10e127796ba 100644
--- a/pulsar-io/core/src/main/java/org/apache/pulsar/io/core/AbstractPushSource.java
+++ b/pulsar-io/core/src/main/java/org/apache/pulsar/io/core/AbstractPushSource.java
@@ -98,6 +98,7 @@ public abstract class AbstractPushSource<T> {
      * Allows the source to notify errors asynchronously.
      * @param ex
      */
+    @SuppressWarnings("unchecked")
     public void notifyError(Exception ex) {
         consume(new ErrorNotifierRecord(ex));
     }