ccaominh commented on a change in pull request #10445:
URL: https://github.com/apache/druid/pull/10445#discussion_r497840982
##########
File path:
indexing-service/src/test/java/org/apache/druid/indexing/common/task/CompactionTaskParallelRunTest.java
##########
@@ -219,6 +219,37 @@ public void testRunParallelWithRangePartitioning()
}
}
+ @Test
+ public void testRunParallelWithRangePartitioningWithSingleTask()
+ {
+ // Range partitioning is not supported with segment lock yet
+ if (lockGranularity == LockGranularity.SEGMENT) {
+ return;
+ }
+ runIndexTask(null, true);
+
+ final Builder builder = new Builder(
+ DATA_SOURCE,
+ getSegmentLoaderFactory(),
+ RETRY_POLICY_FACTORY
+ );
+ final CompactionTask compactionTask = builder
+ .inputSpec(new CompactionIntervalSpec(INTERVAL_TO_INDEX, null))
+ .tuningConfig(newTuningConfig(new SingleDimensionPartitionsSpec(7,
null, "dim", false), 1, true))
+ .build();
+
+ final Set<DataSegment> compactedSegments = runTask(compactionTask);
+ final CompactionState expectedState = new CompactionState(
+ new SingleDimensionPartitionsSpec(7, null, "dim", false),
+
compactionTask.getTuningConfig().getIndexSpec().asMap(getObjectMapper())
+ );
+ for (DataSegment segment : compactedSegments) {
+ // Expecte compaction state to exist as store compaction state by default
Review comment:
There's at least one typo in this comment
##########
File path:
indexing-service/src/test/java/org/apache/druid/indexing/common/task/CompactionTaskParallelRunTest.java
##########
@@ -219,6 +219,37 @@ public void testRunParallelWithRangePartitioning()
}
}
+ @Test
+ public void testRunParallelWithRangePartitioningWithSingleTask()
+ {
+ // Range partitioning is not supported with segment lock yet
+ if (lockGranularity == LockGranularity.SEGMENT) {
+ return;
+ }
Review comment:
[JUnit has an `Assume`
API](https://junit.org/junit4/javadoc/4.12/org/junit/Assume.html), which could
be a good fit here.
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
[email protected]
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
