This is an automated email from the ASF dual-hosted git repository.
jihoonson pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/druid.git.
from b1be88d fix Expressions.toQueryGranularity to be more correct,
improve javadocs of Expr.getIdentifierIfIdentifier and
Expr.getBindingIfIdentifier (#9363)
add 3bb9e7e Inject things instead of subclassing everything for parallel
task testing (#9353)
No new revisions were added by this update.
Summary of changes:
.../druid/indexing/common/task/AbstractTask.java | 3 +-
.../druid/indexing/common/task/CompactionTask.java | 6 +
.../batch/parallel/GenericPartitionLocation.java | 9 +-
.../task/batch/parallel/HashPartitionLocation.java | 7 +-
.../task/batch/parallel/HttpShuffleClient.java | 87 ++++
.../InputSourceSplitParallelIndexTaskRunner.java | 6 +-
...mensionDistributionParallelIndexTaskRunner.java | 3 +-
.../parallel/PartialGenericSegmentMergeTask.java | 4 +-
...HashSegmentGenerateParallelIndexTaskRunner.java | 33 +-
.../parallel/PartialHashSegmentMergeTask.java | 4 +-
...angeSegmentGenerateParallelIndexTaskRunner.java | 42 +-
.../batch/parallel/PartialSegmentMergeTask.java | 43 +-
.../task/batch/parallel/PartitionLocation.java | 7 +
...upervisorTaskAccess.java => ShuffleClient.java} | 40 +-
.../apache/druid/indexing/common/TestUtils.java | 28 --
.../common/task/CompactionTaskParallelRunTest.java | 158 +-----
.../common/task/CompactionTaskRunTest.java | 4 +-
.../indexing/common/task/IngestionTestBase.java | 4 +-
.../AbstractMultiPhaseParallelIndexingTest.java | 54 +-
.../AbstractParallelIndexSupervisorTaskTest.java | 544 +++++++++++++++++----
...ashPartitionMultiPhaseParallelIndexingTest.java | 197 +-------
.../task/batch/parallel/HttpShuffleClientTest.java | 211 ++++++++
.../parallel/ParallelIndexPhaseRunnerTest.java | 33 +-
.../ParallelIndexSupervisorTaskKillTest.java | 51 +-
.../ParallelIndexSupervisorTaskResourceTest.java | 55 +--
.../parallel/ParallelIndexTestingFactory.java | 21 +-
.../PartialGenericSegmentMergeTaskTest.java | 6 +-
.../parallel/PartialHashSegmentMergeTaskTest.java | 6 +-
.../PartialRangeSegmentGenerateTaskTest.java | 7 +-
...ngePartitionMultiPhaseParallelIndexingTest.java | 235 +--------
.../parallel/SinglePhaseParallelIndexingTest.java | 206 ++------
.../realtime/firehose/LocalFirehoseFactory.java | 5 +-
.../main/java/org/apache/druid/cli/CliIndexer.java | 5 -
.../org/apache/druid/cli/CliMiddleManager.java | 2 +
.../java/org/apache/druid/cli/CliOverlord.java | 5 +-
.../main/java/org/apache/druid/cli/CliPeon.java | 14 +-
36 files changed, 967 insertions(+), 1178 deletions(-)
create mode 100644
indexing-service/src/main/java/org/apache/druid/indexing/common/task/batch/parallel/HttpShuffleClient.java
copy
indexing-service/src/main/java/org/apache/druid/indexing/common/task/batch/parallel/{SupervisorTaskAccess.java
=> ShuffleClient.java} (51%)
create mode 100644
indexing-service/src/test/java/org/apache/druid/indexing/common/task/batch/parallel/HttpShuffleClientTest.java
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
