remove future.join() from PulsarSinkEffectivelyOnceProcessor (#6361)

nlu90 · web-flow · commit 943c9035b77d · 2020-02-19T11:43:31.000-08:00
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
@@ -234,7 +234,6 @@ public void sendOutputMessage(TypedMessageBuilder<T> msg, Record<T> record) {
             CompletableFuture<MessageId> future = msg.sendAsync();
 
             future.thenAccept(messageId -> record.ack()).exceptionally(getPublishErrorHandler(record, true));
-            future.join();
         }
     }
 

Original file line number	Diff line number	Diff line change
`@@ -234,7 +234,6 @@ public void sendOutputMessage(TypedMessageBuilder<T> msg, Record<T> record) {`
`234`	`234`	`CompletableFuture<MessageId> future = msg.sendAsync();`
`235`	`235`
`236`	`236`	`future.thenAccept(messageId -> record.ack()).exceptionally(getPublishErrorHandler(record, true));`
`237`		`- future.join();`
`238`	`237`	`}`
`239`	`238`	`}`
`240`	`239`