This is an automated email from the ASF dual-hosted git repository.
kfaraz pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/druid.git
from 6254658f61 docs: fix links (#14111)
add ba11b3d462 Refactor: Add OverlordDuty to replace OverlordHelper and
align with CoordinatorDuty (#14235)
No new revisions were added by this update.
Summary of changes:
.../druid/msq/guice/MSQDurableStorageModule.java | 4 +-
.../druid/msq/indexing/DurableStorageCleaner.java | 111 +++++++++------------
.../msq/indexing/DurableStorageCleanerTest.java | 79 ++++++++-------
.../druid/indexing/common/config/TaskConfig.java | 55 +++++-----
.../apache/druid/indexing/overlord/TaskMaster.java | 6 +-
.../indexing/overlord/config/TaskQueueConfig.java | 3 +-
.../druid/indexing/overlord/duty/DutySchedule.java | 33 +++---
.../OverlordHelper.java => duty/OverlordDuty.java} | 10 +-
.../OverlordDutyExecutor.java} | 77 ++++++++++----
.../{helpers => duty}/TaskLogAutoCleaner.java | 42 +++-----
.../TaskLogAutoCleanerConfig.java | 29 +++---
.../overlord/duty/OverlordDutyExecutorTest.java | 93 +++++++++++++++++
.../TaskLogAutoCleanerConfigTest.java | 2 +-
.../overlord/duty/TaskLogAutoCleanerTest.java | 79 +++++++++++++++
.../druid/indexing/overlord/http/OverlordTest.java | 4 +-
.../org/apache/druid/common/config/Configs.java | 63 ++++++++++++
.../org/apache/druid/tasklogs/TaskLogKiller.java | 1 +
.../apache/druid/common/config/ConfigsTest.java | 26 ++---
.../metadata/SQLMetadataStorageActionHandler.java | 60 +++++------
.../CoordinatorOverlordServiceConfig.java | 11 +-
.../CoordinatorOverlordServiceConfigTest.java} | 18 ++--
.../java/org/apache/druid/cli/CliOverlord.java | 23 ++---
22 files changed, 535 insertions(+), 294 deletions(-)
copy server/src/main/java/org/apache/druid/client/cache/HybridCacheConfig.java
=>
indexing-service/src/main/java/org/apache/druid/indexing/overlord/duty/DutySchedule.java
(65%)
rename
indexing-service/src/main/java/org/apache/druid/indexing/overlord/{helpers/OverlordHelper.java
=> duty/OverlordDuty.java} (80%)
rename
indexing-service/src/main/java/org/apache/druid/indexing/overlord/{helpers/OverlordHelperManager.java
=> duty/OverlordDutyExecutor.java} (51%)
rename
indexing-service/src/main/java/org/apache/druid/indexing/overlord/{helpers =>
duty}/TaskLogAutoCleaner.java (60%)
rename
indexing-service/src/main/java/org/apache/druid/indexing/overlord/{helpers =>
duty}/TaskLogAutoCleanerConfig.java (69%)
create mode 100644
indexing-service/src/test/java/org/apache/druid/indexing/overlord/duty/OverlordDutyExecutorTest.java
rename
indexing-service/src/test/java/org/apache/druid/indexing/overlord/{helpers =>
duty}/TaskLogAutoCleanerConfigTest.java (97%)
create mode 100644
indexing-service/src/test/java/org/apache/druid/indexing/overlord/duty/TaskLogAutoCleanerTest.java
create mode 100644
processing/src/main/java/org/apache/druid/common/config/Configs.java
copy
extensions-core/datasketches/src/test/java/org/apache/druid/query/aggregation/datasketches/theta/SketchEstimateWithErrorBoundsTest.java
=> processing/src/test/java/org/apache/druid/common/config/ConfigsTest.java
(57%)
copy server/src/test/java/org/apache/druid/server/{JettyUtilsTest.java =>
coordinator/CoordinatorOverlordServiceConfigTest.java} (68%)
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
