(pulsar) branch master updated: [improve][build] Fix compile errors from rawtypes/unchecked changes (#25418)

[mmerli]

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 13b52102f5b [improve][build] Fix compile errors from 
rawtypes/unchecked changes (#25418)
13b52102f5b is described below

commit 13b52102f5b0b08bfa8775c9464883a1c3dac429
Author: Matteo Merli <mme...@apache.org>
AuthorDate: Fri Mar 27 17:25:50 2026 -0700

    [improve][build] Fix compile errors from rawtypes/unchecked changes (#25418)
---
 .../apache/pulsar/broker/ManagedLedgerClientFactory.java    | 13 ++++++++++---
 .../main/java/org/apache/pulsar/client/cli/CmdProduce.java  |  5 ++++-
 .../pulsar/functions/instance/JavaInstanceRunnable.java     |  3 +++
 3 files changed, 17 insertions(+), 4 deletions(-)

diff --git 
a/pulsar-broker/src/main/java/org/apache/pulsar/broker/ManagedLedgerClientFactory.java
 
b/pulsar-broker/src/main/java/org/apache/pulsar/broker/ManagedLedgerClientFactory.java
index cc16668790d..77415b4ffce 100644
--- 
a/pulsar-broker/src/main/java/org/apache/pulsar/broker/ManagedLedgerClientFactory.java
+++ 
b/pulsar-broker/src/main/java/org/apache/pulsar/broker/ManagedLedgerClientFactory.java
@@ -31,6 +31,7 @@ import java.util.Optional;
 import java.util.concurrent.CompletableFuture;
 import java.util.concurrent.RejectedExecutionException;
 import org.apache.bookkeeper.client.BookKeeper;
+import org.apache.bookkeeper.client.EnsemblePlacementPolicy;
 import org.apache.bookkeeper.conf.ClientConfiguration;
 import org.apache.bookkeeper.mledger.ManagedLedgerFactory;
 import org.apache.bookkeeper.mledger.ManagedLedgerFactoryConfig;
@@ -140,9 +141,15 @@ public class ManagedLedgerClientFactory implements 
ManagedLedgerStorage {
 
             // find or create bk-client in cache for a specific 
ensemblePlacementPolicy
             return 
bkEnsemblePolicyToBkClientMap.get(ensemblePlacementPolicyConfig,
-                    (config, executor) -> bookkeeperProvider.create(conf, 
metadataStore, eventLoopGroup,
-                            
Optional.ofNullable(ensemblePlacementPolicyConfig.getPolicyClass()),
-                            ensemblePlacementPolicyConfig.getProperties(), 
statsLogger));
+                    (config, executor) -> {
+                        @SuppressWarnings("unchecked")
+                        Class<? extends EnsemblePlacementPolicy> policyClass =
+                                (Class<? extends EnsemblePlacementPolicy>)
+                                        
ensemblePlacementPolicyConfig.getPolicyClass();
+                        return bookkeeperProvider.create(conf, metadataStore, 
eventLoopGroup,
+                                Optional.ofNullable(policyClass),
+                                ensemblePlacementPolicyConfig.getProperties(), 
statsLogger);
+                    });
         };
 
         try {
diff --git 
a/pulsar-client-tools/src/main/java/org/apache/pulsar/client/cli/CmdProduce.java
 
b/pulsar-client-tools/src/main/java/org/apache/pulsar/client/cli/CmdProduce.java
index 69b180eca75..d04642155b5 100644
--- 
a/pulsar-client-tools/src/main/java/org/apache/pulsar/client/cli/CmdProduce.java
+++ 
b/pulsar-client-tools/src/main/java/org/apache/pulsar/client/cli/CmdProduce.java
@@ -195,7 +195,10 @@ public class CmdProduce extends AbstractCmd {
         for (String m : stringMessages) {
             if (schema.getSchemaInfo().getType() == SchemaType.AVRO) {
                 // JSON TO AVRO
-                org.apache.avro.Schema avroSchema = 
((Optional<org.apache.avro.Schema>) schema.getNativeSchema()).get();
+                @SuppressWarnings("unchecked")
+                Optional<org.apache.avro.Schema> nativeSchema =
+                        (Optional<org.apache.avro.Schema>) (Optional<?>) 
schema.getNativeSchema();
+                org.apache.avro.Schema avroSchema = nativeSchema.get();
                 byte[] encoded = jsonToAvro(m, avroSchema);
                 messageBodies.add(encoded);
             } else {
diff --git 
a/pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/instance/JavaInstanceRunnable.java
 
b/pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/instance/JavaInstanceRunnable.java
index 403b28da056..ac824d980f7 100644
--- 
a/pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/instance/JavaInstanceRunnable.java
+++ 
b/pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/instance/JavaInstanceRunnable.java
@@ -141,7 +141,9 @@ public class JavaInstanceRunnable implements AutoCloseable, 
Runnable {
 
     private Record<?> currentRecord;
 
+    @SuppressWarnings("rawtypes")
     private Source source;
+    @SuppressWarnings("rawtypes")
     private Sink sink;
 
     private final SecretsProvider secretsProvider;
@@ -453,6 +455,7 @@ public class JavaInstanceRunnable implements AutoCloseable, 
Runnable {
         stats.processTimeEnd(result.getStartTime());
     }
 
+    @SuppressWarnings({"unchecked", "rawtypes"})
     private void sendOutputMessage(Record srcRecord, Object output) throws 
Exception {
         if (componentType == 
org.apache.pulsar.functions.proto.Function.FunctionDetails.ComponentType.SINK) {
             Thread.currentThread().setContextClassLoader(componentClassLoader);