Skip to content

Commit 3269de5

Browse files
committed
Improve messages.
1 parent 1a8ab17 commit 3269de5

File tree

1 file changed

+4
-4
lines changed

1 file changed

+4
-4
lines changed

multi-stage-query/src/main/java/org/apache/druid/msq/indexing/MSQCompactionRunner.java

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -730,23 +730,23 @@ private static TaskStatus runSubtasks(
730730
}
731731
try {
732732
if (task.isReady(toolbox.getTaskActionClient())) {
733-
log.info("Running MSQControllerTask[%d]: %s", taskCnt, json);
733+
log.info("Running MSQControllerTask number[%d]: %s", taskCnt, json);
734734
final TaskStatus taskStatus = task.run(toolbox);
735735
if (!taskStatus.isSuccess()) {
736736
failCnt++;
737-
log.warn("Failed to run MSQControllerTask[%d]: %s", taskCnt, taskStatus.getErrorMsg());
737+
log.warn("Failed to run MSQControllerTask number[%d]: %s", taskCnt, taskStatus.getErrorMsg());
738738
if (firstFailure == null) {
739739
firstFailure = taskStatus;
740740
}
741741
}
742742
} else {
743743
failCnt++;
744-
log.warn("MSQControllerTask[%d] is not ready.", taskCnt);
744+
log.warn("MSQControllerTask number[%d] is not ready.", taskCnt);
745745
}
746746
}
747747
catch (Exception e) {
748748
failCnt++;
749-
log.warn(e, "Failed to run MSQControllerTask[%d].", taskCnt);
749+
log.warn(e, "Failed to run MSQControllerTask number[%d].", taskCnt);
750750
}
751751
}
752752

0 commit comments

Comments
 (0)