This is an automated email from the ASF dual-hosted git repository.
yqm pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/druid.git
from 4e3dc36440d bump some dependencies to newer versions (#19122)
add 6badd78e8d1 add minor compaction for Overlord based compaction
supervisors using the MSQ engine (#19059)
No new revisions were added by this update.
Summary of changes:
.../embedded/compact/CompactionSupervisorTest.java | 293 +++++++++++++--------
.../common/actions/MarkSegmentToUpgradeAction.java | 102 +++++++
.../druid/indexing/common/actions/TaskAction.java | 1 +
.../indexing/common/task/CompactionInputSpec.java | 1 +
.../indexing/common/task/CompactionRunner.java | 6 +-
.../druid/indexing/common/task/CompactionTask.java | 124 +++++++--
...rvalSpec.java => MinorCompactionInputSpec.java} | 71 ++---
.../common/task/NativeCompactionRunner.java | 40 +--
.../compact/CompactionConfigBasedJobTemplate.java | 28 +-
.../indexing/compact/CompactionJobParams.java | 16 ++
.../druid/indexing/compact/CompactionJobQueue.java | 20 +-
.../actions/MarkSegmentToUpgradeActionTest.java | 161 +++++++++++
.../task/ClientCompactionTaskQuerySerdeTest.java | 2 +-
.../common/task/CompactionTaskRunBase.java | 13 +-
.../indexing/common/task/CompactionTaskTest.java | 73 ++---
.../common/task/MinorCompactionInputSpecTest.java | 104 ++++++++
.../common/task/NativeCompactionRunnerTest.java | 14 +-
.../TestIndexerMetadataStorageCoordinator.java | 13 +-
.../tools/WikipediaStreamEventStreamGenerator.java | 18 ++
.../druid/msq/indexing/MSQCompactionRunner.java | 32 +--
.../druid/msq/exec/MSQCompactionTaskRunTest.java | 172 ++++++++++++
.../msq/indexing/MSQCompactionRunnerTest.java | 18 +-
.../partition/DimensionRangeShardSpec.java | 18 ++
.../druid/timeline/partition/LinearShardSpec.java | 12 +
.../timeline/partition/NumberedShardSpec.java | 18 ++
.../apache/druid/timeline/partition/ShardSpec.java | 27 ++
.../indexing/ClientCompactionIntervalSpec.java | 42 ++-
.../IndexerMetadataStorageCoordinator.java | 10 +
.../IndexerSQLMetadataStorageCoordinator.java | 149 +++++++----
.../server/compaction/CompactionCandidate.java | 6 +
.../CompactionCandidateSearchPolicy.java | 7 +-
.../druid/server/compaction/CompactionMode.java | 6 +-
.../druid/server/compaction/CompactionStatus.java | 32 ++-
.../server/compaction/CompactionStatusTracker.java | 29 +-
.../MostFragmentedIntervalFirstPolicy.java | 54 +++-
.../UserCompactionTaskQueryTuningConfig.java | 167 ++++++++++++
.../server/coordinator/duty/CompactSegments.java | 27 +-
.../apache/druid/server/http/DataSegmentPlus.java | 2 +-
.../indexing/ClientCompactionIntervalSpecTest.java | 42 +++
.../IndexerSQLMetadataStorageCoordinatorTest.java | 146 +++++++++-
.../MostFragmentedIntervalFirstPolicyTest.java | 95 ++++++-
.../UserCompactionTaskQueryTuningConfigTest.java | 79 ++----
.../coordinator/duty/CompactSegmentsTest.java | 1 +
43 files changed, 1902 insertions(+), 389 deletions(-)
create mode 100644
indexing-service/src/main/java/org/apache/druid/indexing/common/actions/MarkSegmentToUpgradeAction.java
copy
indexing-service/src/main/java/org/apache/druid/indexing/common/task/{CompactionIntervalSpec.java
=> MinorCompactionInputSpec.java} (52%)
create mode 100644
indexing-service/src/test/java/org/apache/druid/indexing/common/actions/MarkSegmentToUpgradeActionTest.java
create mode 100644
indexing-service/src/test/java/org/apache/druid/indexing/common/task/MinorCompactionInputSpecTest.java
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
