[pulsar] branch retry_creation updated: Catch interrupted exception

[sa...@apache.org]

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

sanjeevrk pushed a commit to branch retry_creation
in repository https://gitbox.apache.org/repos/asf/pulsar.git


The following commit(s) were added to refs/heads/retry_creation by this push:
     new 2654b10  Catch interrupted exception
2654b10 is described below

commit 2654b10608caab08b4c373eb17d25e5a7cc70ee3
Author: Sanjeev Kulkarni <sa...@streaml.io>
AuthorDate: Mon Mar 4 10:40:27 2019 -0800

    Catch interrupted exception
---
 .../java/org/apache/pulsar/functions/worker/SchedulerManager.java     | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)

diff --git a/pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/SchedulerManager.java b/pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/SchedulerManager.java
index e19258c..c281b15 100644
--- a/pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/SchedulerManager.java
+++ b/pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/SchedulerManager.java
@@ -127,7 +127,9 @@ public class SchedulerManager implements AutoCloseable {
                             .build())
                     .run();
         } catch (InterruptedException e) {
-
+            log.error("Interrupted at creating producer to topic {}", config.getFunctionAssignmentTopic(), e);
+            Thread.currentThread().interrupt();
+            throw new RuntimeException(e);
         }
         if (producer.get() == null) {
             throw new RuntimeException("Can't create a producer on assignment topic "