This is an automated email from the ASF dual-hosted git repository.
himanshug pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-druid.git.
from d54d2e1 Update segments.md (#8693)
add 2c758ef Support assign tasks to run on different categories of
MiddleManagers (#7066)
No new revisions were added by this update.
Summary of changes:
docs/configuration/index.md | 60 +++++++
...PendingTaskBasedWorkerProvisioningStrategy.java | 3 +-
.../overlord/hrtr/HttpRemoteTaskRunner.java | 3 +-
.../druid/indexing/overlord/hrtr/WorkerHolder.java | 3 +-
...utionWithCategorySpecWorkerSelectStrategy.java} | 39 ++---
.../EqualDistributionWorkerSelectStrategy.java | 2 +-
...acityWithCategorySpecWorkerSelectStrategy.java} | 37 ++--
.../setup/FillCapacityWorkerSelectStrategy.java | 2 +-
.../overlord/setup/WorkerCategorySpec.java | 143 ++++++++++++++++
.../overlord/setup/WorkerSelectStrategy.java | 4 +-
.../indexing/overlord/setup/WorkerSelectUtils.java | 92 +++++++++-
.../org/apache/druid/indexing/worker/Worker.java | 18 +-
.../druid/indexing/worker/http/WorkerResource.java | 3 +-
.../indexing/overlord/ImmutableWorkerInfoTest.java | 50 ++++--
.../overlord/RemoteTaskRunnerTestUtils.java | 13 +-
.../indexing/overlord/TaskRunnerUtilsTest.java | 3 +-
.../overlord/WorkerTaskRunnerQueryAdpaterTest.java | 5 +-
.../PendingTaskBasedProvisioningStrategyTest.java | 3 +-
.../SimpleProvisioningStrategyTest.java | 3 +-
.../overlord/hrtr/HttpRemoteTaskRunnerTest.java | 35 ++--
.../indexing/overlord/hrtr/WorkerHolderTest.java | 3 +-
...butionWithAffinityWorkerSelectStrategyTest.java | 51 +++---
...onWithCategorySpecWorkerSelectStrategyTest.java | 190 +++++++++++++++++++++
.../EqualDistributionWorkerSelectStrategyTest.java | 25 +--
...pacityWithAffinityWorkerSelectStrategyTest.java | 11 +-
...tyWithCategorySpecWorkerSelectStrategyTest.java | 190 +++++++++++++++++++++
.../overlord/setup/WorkerCategorySpecTest.java | 49 +++---
.../indexing/worker/WorkerTaskMonitorTest.java | 4 +-
.../indexing/worker/http/WorkerResourceTest.java | 4 +-
.../apache/druid/discovery/WorkerNodeService.java | 17 +-
.../druid/indexing/worker/config/WorkerConfig.java | 11 ++
.../druid/discovery/WorkerNodeServiceTest.java | 3 +-
.../main/java/org/apache/druid/cli/CliIndexer.java | 6 +-
.../org/apache/druid/cli/CliMiddleManager.java | 6 +-
website/.spelling | 10 ++
35 files changed, 923 insertions(+), 178 deletions(-)
copy
indexing-service/src/main/java/org/apache/druid/indexing/overlord/setup/{EqualDistributionWorkerSelectStrategy.java
=> EqualDistributionWithCategorySpecWorkerSelectStrategy.java} (65%)
copy
indexing-service/src/main/java/org/apache/druid/indexing/overlord/setup/{FillCapacityWorkerSelectStrategy.java
=> FillCapacityWithCategorySpecWorkerSelectStrategy.java} (66%)
create mode 100644
indexing-service/src/main/java/org/apache/druid/indexing/overlord/setup/WorkerCategorySpec.java
create mode 100644
indexing-service/src/test/java/org/apache/druid/indexing/overlord/setup/EqualDistributionWithCategorySpecWorkerSelectStrategyTest.java
create mode 100644
indexing-service/src/test/java/org/apache/druid/indexing/overlord/setup/FillCapacityWithCategorySpecWorkerSelectStrategyTest.java
copy core/src/test/java/org/apache/druid/js/JavaScriptConfigTest.java =>
indexing-service/src/test/java/org/apache/druid/indexing/overlord/setup/WorkerCategorySpecTest.java
(51%)
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
