diff --git a/server/src/main/java/org/apache/druid/server/QueryLifecycle.java b/server/src/main/java/org/apache/druid/server/QueryLifecycle.java index 8f0deafac2b..0f46e5da4d9 100644 --- a/server/src/main/java/org/apache/druid/server/QueryLifecycle.java +++ b/server/src/main/java/org/apache/druid/server/QueryLifecycle.java @@ -347,7 +347,7 @@ public class QueryLifecycle if (e != null) { statsMap.put("exception", e.toString()); - if (baseQuery.context().isDebug()) { + if (baseQuery.context().isDebug() || e.getMessage() == null) { log.warn(e, "Exception while processing queryId [%s]", baseQuery.getId()); } else { log.noStackTrace().warn(e, "Exception while processing queryId [%s]", baseQuery.getId());