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 909abd7e8f2 docs: update zookeeper version (#18836)
add 806bfada14d Fix MSQ compaction state and native interval locking, add
test coverage (#18950)
No new revisions were added by this update.
Summary of changes:
.../common/task/AbstractBatchIndexTask.java | 37 -
.../indexing/common/task/CompactionIOConfig.java | 6 +-
.../druid/indexing/common/task/CompactionTask.java | 38 +-
.../task/batch/parallel/TombstoneHelper.java | 8 +-
.../indexing/common/actions/TaskActionTestKit.java | 92 +-
.../common/task/CompactionTaskParallelRunTest.java | 4 +-
...TaskRunTest.java => CompactionTaskRunBase.java} | 1861 +++++++++-----------
.../indexing/common/task/CompactionTaskTest.java | 10 +-
.../common/task/NativeCompactionTaskRunTest.java | 109 ++
.../apache/druid/msq/guice/MSQIndexingModule.java | 22 +
.../indexing/IndexerControllerContextFactory.java | 27 +-
.../druid/msq/indexing/MSQCompactionRunner.java | 19 +-
.../druid/msq/indexing/MSQControllerTask.java | 19 +-
.../destination/SegmentGenerationUtils.java | 40 +-
.../druid/msq/exec/MSQCompactionTaskRunTest.java | 616 +++++++
.../org/apache/druid/msq/exec/MSQReplaceTest.java | 66 +-
.../msq/indexing/MSQCompactionRunnerTest.java | 2 +-
.../druid/msq/test/MSQTestControllerContext.java | 37 +-
.../druid/data/input/impl/DimensionsSpec.java | 5 +
.../org/apache/druid/timeline/CompactionState.java | 90 +-
.../data/input/impl/DimensionsSpecSerdeTest.java | 94 +-
.../apache/druid/timeline/CompactionStateTest.java | 228 +++
.../server/coordinator/duty/CompactSegments.java | 3 +
.../coordinator/duty/CompactSegmentsTest.java | 6 +-
24 files changed, 2210 insertions(+), 1229 deletions(-)
rename
indexing-service/src/test/java/org/apache/druid/indexing/common/task/{CompactionTaskRunTest.java
=> CompactionTaskRunBase.java} (53%)
create mode 100644
indexing-service/src/test/java/org/apache/druid/indexing/common/task/NativeCompactionTaskRunTest.java
copy server/src/main/java/org/apache/druid/server/GuiceServletConfig.java =>
multi-stage-query/src/main/java/org/apache/druid/msq/indexing/IndexerControllerContextFactory.java
(51%)
create mode 100644
multi-stage-query/src/test/java/org/apache/druid/msq/exec/MSQCompactionTaskRunTest.java
create mode 100644
processing/src/test/java/org/apache/druid/timeline/CompactionStateTest.java
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
