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 cab977e  add function-name reference with function failure log (#2246)
cab977e is described below

commit cab977e785d9db6e8a96f304585b8858f70c97b0
Author: Rajan Dhabalia <rdhaba...@apache.org>
AuthorDate: Thu Jul 26 23:36:06 2018 -0700

    add function-name reference with function failure log (#2246)
---
 .../main/java/org/apache/pulsar/functions/runtime/RuntimeSpawner.java | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)

diff --git 
a/pulsar-functions/runtime/src/main/java/org/apache/pulsar/functions/runtime/RuntimeSpawner.java
 
b/pulsar-functions/runtime/src/main/java/org/apache/pulsar/functions/runtime/RuntimeSpawner.java
index 8329ed7..6abb5fb 100644
--- 
a/pulsar-functions/runtime/src/main/java/org/apache/pulsar/functions/runtime/RuntimeSpawner.java
+++ 
b/pulsar-functions/runtime/src/main/java/org/apache/pulsar/functions/runtime/RuntimeSpawner.java
@@ -82,7 +82,9 @@ public class RuntimeSpawner implements AutoCloseable {
                 @Override
                 public void run() {
                     if (!runtime.isAlive()) {
-                        log.error("Function Container is dead with exception", 
runtime.getDeathException());
+                        log.error("[{}-{}] Function Container is dead with 
exception",
+                                instanceConfig.getFunctionDetails().getName(), 
instanceConfig.getInstanceId(),
+                                runtime.getDeathException());
                         log.error("Restarting...");
                         // Just for the sake of sanity, just destroy the 
runtime
                         runtime.stop();

Reply via email to