You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@druid.apache.org by gi...@apache.org on 2019/11/23 09:38:23 UTC
[incubator-druid] branch master updated (e0eb85a -> a2e6de4)
This is an automated email from the ASF dual-hosted git repository.
gian pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-druid.git.
from e0eb85a Add FileUtils.createTempDir() and enforce its usage. (#8932)
add a2e6de4 Fix the potential race between SplittableInputSource.getNumSplits() and SplittableInputSource.createSplits() in TaskMonitor (#8924)
No new revisions were added by this update.
Summary of changes:
.../input/FirehoseFactoryToInputSourceAdaptor.java | 2 +-
.../org/apache/druid/data/input/SplitHintSpec.java | 2 +-
.../druid/data/input/impl/HttpInputSource.java | 2 +-
.../druid/data/input/impl/LocalInputSource.java | 2 +-
.../data/input/impl/SplittableInputSource.java | 16 +-
docs/ingestion/native-batch.md | 4 +-
.../google/GoogleCloudStorageInputSource.java | 2 +-
.../druid/inputsource/hdfs/HdfsInputSource.java | 2 +-
.../inputsource/hdfs/HdfsInputSourceTest.java | 4 +-
.../InputSourceSplitParallelIndexTaskRunner.java | 4 +-
.../batch/parallel/ParallelIndexPhaseRunner.java | 48 ++++-
.../batch/parallel/ParallelIndexTaskRunner.java | 4 +-
...ess.java => ParallelIndexingPhaseProgress.java} | 24 ++-
.../batch/parallel/ParallelIndexingProgress.java | 28 ---
...ialHashSegmentMergeParallelIndexTaskRunner.java | 2 +-
.../SinglePhaseParallelIndexTaskRunner.java | 4 +-
.../common/task/batch/parallel/TaskMonitor.java | 69 +++---
.../AbstractParallelIndexSupervisorTaskTest.java | 28 +++
.../parallel/ParallelIndexPhaseRunnerTest.java | 238 +++++++++++++++++++++
.../ParallelIndexSupervisorTaskKillTest.java | 4 +-
.../ParallelIndexSupervisorTaskResourceTest.java | 24 +--
.../parallel/SinglePhaseParallelIndexingTest.java | 31 +--
22 files changed, 399 insertions(+), 145 deletions(-)
rename indexing-service/src/main/java/org/apache/druid/indexing/common/task/batch/parallel/{SinglePhaseParallelIndexingProgress.java => ParallelIndexingPhaseProgress.java} (72%)
delete mode 100644 indexing-service/src/main/java/org/apache/druid/indexing/common/task/batch/parallel/ParallelIndexingProgress.java
create mode 100644 indexing-service/src/test/java/org/apache/druid/indexing/common/task/batch/parallel/ParallelIndexPhaseRunnerTest.java
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@druid.apache.org
For additional commands, e-mail: commits-help@druid.apache.org