diff --git a/merger/src/main/java/com/metamx/druid/merger/common/actions/RemoteTaskActionClient.java b/merger/src/main/java/com/metamx/druid/merger/common/actions/RemoteTaskActionClient.java index 8059c4d4ea3..ca9fe9c5c73 100644 --- a/merger/src/main/java/com/metamx/druid/merger/common/actions/RemoteTaskActionClient.java +++ b/merger/src/main/java/com/metamx/druid/merger/common/actions/RemoteTaskActionClient.java @@ -82,6 +82,8 @@ public class RemoteTaskActionClient implements TaskActionClient return jsonMapper.convertValue(responseDict.get("result"), taskAction.getReturnTypeReference()); } catch(IOException e) { + log.warn(e, "Exception submitting action for task: %s", task.getId()); + if (retryPolicy.hasExceededRetryThreshold()) { throw e; } else {