You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@druid.apache.org by jo...@apache.org on 2020/08/27 00:08:34 UTC
[druid] branch master updated (21703d8 -> f82fd22)
This is an automated email from the ASF dual-hosted git repository.
jonwei pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/druid.git.
from 21703d8 Fix handling of 'join' on top of 'union' datasources. (#10318)
add f82fd22 Move tools for indexing to TaskToolbox instead of injecting them in constructor (#10308)
No new revisions were added by this update.
Summary of changes:
.../IncrementalPublishingKafkaIndexTaskRunner.java | 10 --
.../druid/indexing/kafka/KafkaIndexTask.java | 19 +--
.../indexing/kafka/supervisor/KafkaSupervisor.java | 6 +-
.../druid/indexing/kafka/KafkaIndexTaskTest.java | 17 ++-
.../kafka/supervisor/KafkaSupervisorTest.java | 7 +-
.../druid/indexing/kinesis/KinesisIndexTask.java | 19 +--
.../indexing/kinesis/KinesisIndexTaskRunner.java | 10 --
.../kinesis/supervisor/KinesisSupervisor.java | 6 +-
.../kinesis/KinesisIndexTaskSerdeTest.java | 4 -
.../indexing/kinesis/KinesisIndexTaskTest.java | 31 +++--
.../kinesis/supervisor/KinesisSupervisorTest.java | 7 +-
.../apache/druid/indexing/common/TaskToolbox.java | 78 +++++++++++-
.../druid/indexing/common/TaskToolboxFactory.java | 47 ++++++-
.../task/AppenderatorDriverRealtimeIndexTask.java | 48 ++-----
.../druid/indexing/common/task/CompactionTask.java | 84 +------------
.../indexing/common/task/HadoopIndexTask.java | 5 +-
.../druid/indexing/common/task/IndexTask.java | 88 +++++--------
.../GeneratedPartitionsMetadataReport.java | 2 +-
.../InputSourceSplitParallelIndexTaskRunner.java | 7 +-
.../batch/parallel/LegacySinglePhaseSubTask.java | 14 +--
.../batch/parallel/ParallelIndexPhaseRunner.java | 14 +--
.../parallel/ParallelIndexSupervisorTask.java | 59 +++------
...mensionDistributionParallelIndexTaskRunner.java | 39 +-----
.../parallel/PartialDimensionDistributionTask.java | 23 +---
...GenericSegmentMergeParallelIndexTaskRunner.java | 11 +-
.../parallel/PartialGenericSegmentMergeTask.java | 13 +-
...HashSegmentGenerateParallelIndexTaskRunner.java | 11 +-
.../parallel/PartialHashSegmentGenerateTask.java | 12 +-
...angeSegmentGenerateParallelIndexTaskRunner.java | 9 +-
.../parallel/PartialRangeSegmentGenerateTask.java | 12 +-
.../batch/parallel/PartialSegmentGenerateTask.java | 21 +---
.../batch/parallel/PartialSegmentMergeTask.java | 19 +--
.../SinglePhaseParallelIndexTaskRunner.java | 7 +-
.../task/batch/parallel/SinglePhaseSubTask.java | 21 +---
.../batch/parallel/SinglePhaseSubTaskSpec.java | 11 +-
.../seekablestream/SeekableStreamIndexTask.java | 24 +---
.../SeekableStreamIndexTaskRunner.java | 40 +++---
.../druid/indexing/common/TaskToolboxTest.java | 13 ++
.../AppenderatorDriverRealtimeIndexTaskTest.java | 35 ++----
.../task/ClientCompactionTaskQuerySerdeTest.java | 9 +-
.../common/task/CompactionTaskParallelRunTest.java | 60 +--------
.../common/task/CompactionTaskRunTest.java | 104 +++------------
.../indexing/common/task/CompactionTaskTest.java | 86 ++++---------
.../druid/indexing/common/task/IndexTaskTest.java | 139 ++++-----------------
.../indexing/common/task/IngestionTestBase.java | 11 ++
.../common/task/RealtimeIndexTaskTest.java | 22 ++--
.../druid/indexing/common/task/TaskSerdeTest.java | 8 --
.../AbstractMultiPhaseParallelIndexingTest.java | 7 +-
.../AbstractParallelIndexSupervisorTaskTest.java | 82 +++---------
.../parallel/ParallelIndexPhaseRunnerTest.java | 7 +-
.../ParallelIndexSupervisorTaskKillTest.java | 47 +++----
.../ParallelIndexSupervisorTaskResourceTest.java | 36 ++----
.../ParallelIndexSupervisorTaskSerdeTest.java | 21 +---
.../parallel/ParallelIndexSupervisorTaskTest.java | 5 -
.../task/batch/parallel/PartialCompactionTest.java | 13 +-
.../PartialDimensionDistributionTaskTest.java | 49 ++++----
.../PartialGenericSegmentMergeTaskTest.java | 5 +-
.../PartialHashSegmentGenerateTaskTest.java | 5 +-
.../PartialRangeSegmentGenerateTaskTest.java | 9 +-
.../parallel/SinglePhaseParallelIndexingTest.java | 13 +-
.../overlord/SingleTaskBackgroundRunnerTest.java | 12 ++
.../druid/indexing/overlord/TaskLifecycleTest.java | 66 +++++-----
.../SeekableStreamSupervisorStateTest.java | 14 +--
.../indexing/worker/WorkerTaskManagerTest.java | 28 ++---
.../indexing/worker/WorkerTaskMonitorTest.java | 15 ++-
.../org/apache/druid/cli/CliMiddleManager.java | 3 +-
.../java/org/apache/druid/cli/CliOverlord.java | 3 +-
67 files changed, 549 insertions(+), 1233 deletions(-)
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@druid.apache.org
For additional commands, e-mail: commits-help@druid.apache.org