diff --git a/pulsar-functions/instance/pom.xml b/pulsar-functions/instance/pom.xml index 7e4c5b18e2d8b..0929d5ff2101b 100644 --- a/pulsar-functions/instance/pom.xml +++ b/pulsar-functions/instance/pom.xml @@ -95,12 +95,6 @@ ${project.parent.version} - - ${project.groupId} - pulsar-otel-metrics-provider - ${project.version} - - org.apache.bookkeeper stream-storage-java-client diff --git a/pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/instance/ContextImpl.java b/pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/instance/ContextImpl.java index dee0f0dee7745..6664a00510e56 100644 --- a/pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/instance/ContextImpl.java +++ b/pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/instance/ContextImpl.java @@ -731,7 +731,7 @@ public void setUnderlyingBuilder(TypedMessageBuilder underlyingBuilder) { @Override public void close() { - List> futures = new LinkedList<>(); + List futures = new LinkedList<>(); if (publishProducers != null) { for (Producer producer : publishProducers.values()) { diff --git a/pulsar-functions/instance/src/test/java/org/apache/pulsar/functions/instance/ContextImplTest.java b/pulsar-functions/instance/src/test/java/org/apache/pulsar/functions/instance/ContextImplTest.java index 9285e395015d0..6516b9284c9ca 100644 --- a/pulsar-functions/instance/src/test/java/org/apache/pulsar/functions/instance/ContextImplTest.java +++ b/pulsar-functions/instance/src/test/java/org/apache/pulsar/functions/instance/ContextImplTest.java @@ -96,7 +96,6 @@ public void setup() throws PulsarClientException { .setUserConfig("") .build(); config.setFunctionDetails(functionDetails); - config.setClusterName("test-cluster"); logger = mock(Logger.class); pulsarAdmin = mock(PulsarAdmin.class);