diff --git a/indexing-service/src/main/java/org/apache/druid/indexing/common/task/batch/parallel/PartialSegmentMergeTask.java b/indexing-service/src/main/java/org/apache/druid/indexing/common/task/batch/parallel/PartialSegmentMergeTask.java index bac0415c136..3c552c0c889 100644 --- a/indexing-service/src/main/java/org/apache/druid/indexing/common/task/batch/parallel/PartialSegmentMergeTask.java +++ b/indexing-service/src/main/java/org/apache/druid/indexing/common/task/batch/parallel/PartialSegmentMergeTask.java @@ -220,7 +220,7 @@ public class PartialSegmentMergeTask extends AbstractBatchIndexTask final Map intervalToVersion = new HashMap<>(locks.size()); locks.forEach(lock -> { if (lock.isRevoked()) { - throw new ISE("Lock[%s] is revoked"); + throw new ISE("Lock[%s] is revoked", lock); } final String mustBeNull = intervalToVersion.put(lock.getInterval(), lock.getVersion()); if (mustBeNull != null) { diff --git a/server/src/main/java/org/apache/druid/client/DirectDruidClient.java b/server/src/main/java/org/apache/druid/client/DirectDruidClient.java index 4c5017435e6..60bdde4094d 100644 --- a/server/src/main/java/org/apache/druid/client/DirectDruidClient.java +++ b/server/src/main/java/org/apache/druid/client/DirectDruidClient.java @@ -485,6 +485,7 @@ public class DirectDruidClient implements QueryRunner if (res.getStatus().getCode() >= 500) { throw new RE( "Error cancelling query[%s]: queriable node returned status[%d] [%s].", + query, res.getStatus().getCode(), res.getStatus().getReasonPhrase() );