gargvishesh commented on code in PR #16291:
URL: https://github.com/apache/druid/pull/16291#discussion_r1618175892
##########
indexing-service/src/main/java/org/apache/druid/indexing/common/task/CompactionTask.java:
##########
@@ -164,21 +157,17 @@ public class CompactionTask extends
AbstractBatchIndexTask implements PendingSeg
private final ClientCompactionTaskGranularitySpec granularitySpec;
@Nullable
private final CompactionTuningConfig tuningConfig;
+ @Nullable
+ private final CompactionStrategy compactionStrategy;
@JsonIgnore
private final SegmentProvider segmentProvider;
@JsonIgnore
private final PartitionConfigurationManager partitionConfigurationManager;
-
@JsonIgnore
private final SegmentCacheManagerFactory segmentCacheManagerFactory;
@JsonIgnore
- private final CurrentSubTaskHolder currentSubTaskHolder = new
CurrentSubTaskHolder(
- (taskObject, config) -> {
- final ParallelIndexSupervisorTask indexTask =
(ParallelIndexSupervisorTask) taskObject;
- indexTask.stopGracefully(config);
- }
- );
+ private final CurrentSubTaskHolder currentSubTaskHolder;
Review Comment:
Used by tests for extracting the Supervisor task. So leaving it for now.
--
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.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
