From 5bf8e227e248af2701cb3fb0b7343e46db4aebc5 Mon Sep 17 00:00:00 2001
From: Parag Jain <paragjain16@gmail.com>
Date: Thu, 7 Dec 2017 14:35:51 -0600
Subject: [PATCH] prevent NPE from supressing actual exception

---
 .../main/java/io/druid/indexing/kafka/KafkaIndexTask.java    | 5 ++++-
 1 file changed, 4 insertions(+), 1 deletion(-)

diff --git a/extensions-core/kafka-indexing-service/src/main/java/io/druid/indexing/kafka/KafkaIndexTask.java b/extensions-core/kafka-indexing-service/src/main/java/io/druid/indexing/kafka/KafkaIndexTask.java
index 312fd1c8cbca..6a17872d7230 100644
--- a/extensions-core/kafka-indexing-service/src/main/java/io/druid/indexing/kafka/KafkaIndexTask.java
+++ b/extensions-core/kafka-indexing-service/src/main/java/io/druid/indexing/kafka/KafkaIndexTask.java
@@ -883,7 +883,10 @@ public void onFailure(Throwable t)
       if (chatHandlerProvider.isPresent()) {
         chatHandlerProvider.get().unregister(getId());
       }
-      publishExecService.shutdownNow();
+
+      if (publishExecService != null) {
+        publishExecService.shutdownNow();
+      }
 
       toolbox.getDruidNodeAnnouncer().unannounce(discoveryDruidNode);
       toolbox.getDataSegmentServerAnnouncer().unannounce();