[pulsar] 43/47: remove future.join() from PulsarSinkEffectivelyOnceProcessor (#6361)

[guangning]

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

guangning pushed a commit to branch branch-2.5
in repository https://gitbox.apache.org/repos/asf/pulsar.git

commit 48938354a792f5cacff7e82e3bb06ef38126228e
Author: Neng Lu <freen...@gmail.com>
AuthorDate: Wed Feb 19 11:43:31 2020 -0800

    remove future.join() from PulsarSinkEffectivelyOnceProcessor (#6361)
---
 .../src/main/java/org/apache/pulsar/functions/sink/PulsarSink.java       | 1 -
 1 file changed, 1 deletion(-)

diff --git 
a/pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/sink/PulsarSink.java
 
b/pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/sink/PulsarSink.java
index f4763b8..05a08d1 100644
--- 
a/pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/sink/PulsarSink.java
+++ 
b/pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/sink/PulsarSink.java
@@ -234,7 +234,6 @@ public class PulsarSink<T> implements Sink<T> {
             CompletableFuture<MessageId> future = msg.sendAsync();
 
             future.thenAccept(messageId -> 
record.ack()).exceptionally(getPublishErrorHandler(record, true));
-            future.join();
         }
     }