Revert pulsar-functions-instance changes

apache · Feb 1, 2024 · dd80990 · dd80990
1 parent 1c4b4c0
commit dd80990
Show file tree

Hide file tree

Showing 3 changed files with 1 addition and 8 deletions.
diff --git a/pulsar-functions/instance/pom.xml b/pulsar-functions/instance/pom.xml
@@ -95,12 +95,6 @@
       <version>${project.parent.version}</version>
     </dependency>
 
-    <dependency>
-      <groupId>${project.groupId}</groupId>
-      <artifactId>pulsar-otel-metrics-provider</artifactId>
-      <version>${project.version}</version>
-    </dependency>
-
     <dependency>
       <groupId>org.apache.bookkeeper</groupId>
       <artifactId>stream-storage-java-client</artifactId>

diff --git a/...ar-functions/instance/src/main/java/org/apache/pulsar/functions/instance/ContextImpl.java b/...ar-functions/instance/src/main/java/org/apache/pulsar/functions/instance/ContextImpl.java
@@ -731,7 +731,7 @@ public void setUnderlyingBuilder(TypedMessageBuilder<T> underlyingBuilder) {
 
     @Override
     public void close() {
-        List<CompletableFuture<?>> futures = new LinkedList<>();
+        List<CompletableFuture> futures = new LinkedList<>();
 
         if (publishProducers != null) {
             for (Producer<?> producer : publishProducers.values()) {

diff --git a/...unctions/instance/src/test/java/org/apache/pulsar/functions/instance/ContextImplTest.java b/...unctions/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);