Skip to content

Commit d3adbf5

Browse files
committed
fixup misc typos in comments
1 parent 2ace943 commit d3adbf5

3 files changed

Lines changed: 8 additions & 6 deletions

File tree

integration-tests/src/main/java/org/apache/druid/testing/utils/MsqTestQueryHelper.java

Lines changed: 5 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -130,9 +130,11 @@ public SqlTaskStatus submitMsqTask(SqlQuery sqlQuery) throws ExecutionException,
130130
HttpResponseStatus httpResponseStatus = statusResponseHolder.getStatus();
131131
if (!httpResponseStatus.equals(HttpResponseStatus.ACCEPTED)) {
132132
throw new ISE(
133-
"Unable to submit the task successfully. Received response status code [%d], and response content:\n[%s]",
134-
httpResponseStatus,
135-
statusResponseHolder.getContent()
133+
StringUtils.format(
134+
"Unable to submit the task successfully. Received response status code [%d], and response content:\n[%s]",
135+
httpResponseStatus.getCode(),
136+
statusResponseHolder.getContent()
137+
)
136138
);
137139
}
138140
String content = statusResponseHolder.getContent();

processing/src/main/java/org/apache/druid/timeline/partition/OverwriteShardSpec.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -30,7 +30,7 @@ public interface OverwriteShardSpec extends ShardSpec
3030
{
3131
/**
3232
* The core partition concept is not used with segment locking. Instead, the {@link AtomicUpdateGroup} is used
33-
* to atomically overshadow segments. Here, we always returns 0 so that the {@link PartitionHolder} skips checking
33+
* to atomically overshadow segments. Here, we always return 0 so that the {@link PartitionHolder} skips checking
3434
* the completeness of the core partitions.
3535
*/
3636
@Override

server/src/main/java/org/apache/druid/server/coordinator/duty/CompactSegments.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -373,7 +373,7 @@ private int submitCompactionTasks(
373373

374374
final String dataSourceName = segmentsToCompact.get(0).getDataSource();
375375

376-
// As these segments will be compacted, we will aggregates the statistic to the Compacted statistics
376+
// As these segments will be compacted, we will aggregate the statistic to the Compacted statistics
377377
AutoCompactionSnapshot.Builder snapshotBuilder = currentRunAutoCompactionSnapshotBuilders.computeIfAbsent(
378378
dataSourceName,
379379
k -> new AutoCompactionSnapshot.Builder(k, AutoCompactionSnapshot.AutoCompactionScheduleStatus.RUNNING)
@@ -395,7 +395,7 @@ private int submitCompactionTasks(
395395
Granularity segmentGranularityToUse = null;
396396
if (config.getGranularitySpec() == null || config.getGranularitySpec().getSegmentGranularity() == null) {
397397
// Determines segmentGranularity from the segmentsToCompact
398-
// Each batch of segmentToCompact from CompactionSegmentIterator will contains the same interval as
398+
// Each batch of segmentToCompact from CompactionSegmentIterator will contain the same interval as
399399
// segmentGranularity is not set in the compaction config
400400
Interval interval = segmentsToCompact.get(0).getInterval();
401401
if (segmentsToCompact.stream().allMatch(segment -> interval.overlaps(segment.getInterval()))) {

0 commit comments

Comments
 (0)