This is an automated email from the ASF dual-hosted git repository. sijie pushed a commit to branch branch-2.1 in repository https://gitbox.apache.org/repos/asf/incubator-pulsar.git
The following commit(s) were added to refs/heads/branch-2.1 by this push: new b335e94 Set empty response to complete grpc txn (#2225) b335e94 is described below commit b335e94b8541c4b1e4536aa12d700ea06082dc5f Author: Rajan Dhabalia <rdhaba...@apache.org> AuthorDate: Wed Jul 25 13:07:52 2018 -0700 Set empty response to complete grpc txn (#2225) --- .../java/org/apache/pulsar/functions/runtime/JavaInstanceMain.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/pulsar-functions/runtime/src/main/java/org/apache/pulsar/functions/runtime/JavaInstanceMain.java b/pulsar-functions/runtime/src/main/java/org/apache/pulsar/functions/runtime/JavaInstanceMain.java index 0c10fdb..966740d 100644 --- a/pulsar-functions/runtime/src/main/java/org/apache/pulsar/functions/runtime/JavaInstanceMain.java +++ b/pulsar-functions/runtime/src/main/java/org/apache/pulsar/functions/runtime/JavaInstanceMain.java @@ -370,9 +370,10 @@ public class JavaInstanceMain implements AutoCloseable { if (runtime != null) { try { runtime.resetMetrics().get(); + responseObserver.onNext(com.google.protobuf.Empty.getDefaultInstance()); responseObserver.onCompleted(); } catch (InterruptedException | ExecutionException e) { - log.error("Exception in JavaInstance doing getAndResetMetrics", e); + log.error("Exception in JavaInstance doing resetMetrics", e); throw new RuntimeException(e); } }