log exceptions while trying to pause task (apache#3504)

Igosuki · Sep 23, 2016 · 15c9918 · 15c9918
1 parent d5a8a35
commit 15c9918
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/...re/kafka-indexing-service/src/main/java/io/druid/indexing/kafka/KafkaIndexTaskClient.java b/...re/kafka-indexing-service/src/main/java/io/druid/indexing/kafka/KafkaIndexTaskClient.java
@@ -176,6 +176,7 @@ public Map<Integer, Long> pause(final String id, final long timeout)
       );
 
       if (response.getStatus().equals(HttpResponseStatus.OK)) {
+        log.info("Task [%s] paused successfully", id);
         return jsonMapper.readValue(response.getContent(), new TypeReference<Map<Integer, Long>>() {});
       }
 
@@ -187,6 +188,7 @@ public Map<Integer, Long> pause(final String id, final long timeout)
 
         final Duration delay = retryPolicy.getAndIncrementRetryDelay();
         if (delay == null) {
+          log.error("Task [%s] failed to pause, aborting", id);
           throw new ISE("Task [%s] failed to pause, aborting", id);
         } else {
           final long sleepTime = delay.getMillis();
@@ -200,9 +202,11 @@ public Map<Integer, Long> pause(final String id, final long timeout)
       }
     }
     catch (NoTaskLocationException e) {
+      log.error("Exception [%s] while pausing Task [%s]", e.getMessage(), id);
       return ImmutableMap.of();
     }
     catch (IOException | InterruptedException e) {
+      log.error("Exception [%s] while pausing Task [%s]", e.getMessage(), id);
       throw Throwables.propagate(e);
     }
   }