This is an automated email from the ASF dual-hosted git repository. abhishekrb pushed a commit to branch peon_server_priorities in repository https://gitbox.apache.org/repos/asf/druid.git
commit a05aa73c73d9085288060ba17c6f85333a06fe71 Merge: ad0abca18e8 68072e2c006 Author: Abhishek Balaji Radhakrishnan <[email protected]> AuthorDate: Mon Feb 23 16:50:56 2026 -0800 Merge branch 'master' into peon_server_priorities .github/workflows/cron-job-its.yml | 15 - .github/workflows/standard-its.yml | 16 - .../unit-and-integration-tests-unified.yml | 6 +- embedded-tests/pom.xml | 6 + .../embedded/auth/EmbeddedSSLAuthResource.java | 152 ++ .../druid/testing/embedded/auth/TLSTest.java | 491 ++++++ .../embedded/auth/TestTLSCertificateChecker.java | 14 +- .../auth/TestTLSCertificateCheckerModule.java | 11 +- .../embedded/compact/AutoCompactionTest.java | 2 +- .../embedded/compact/CompactionSupervisorTest.java | 400 ++++- .../KubernetesTaskRunnerCachingModeDockerTest.java | 3 + .../KubernetesTaskRunnerDirectModeDockerTest.java | 3 + .../org.apache.druid.initialization.DruidModule | 1 + indexing-service/pom.xml | 20 + .../org/apache/druid/guice/SupervisorModule.java | 4 +- .../common/task/NativeCompactionRunner.java | 8 + .../compact/CascadingReindexingTemplate.java | 806 ++++++++++ .../compact/CompactionConfigBasedJobTemplate.java | 15 +- .../indexing/compact/CompactionSupervisorSpec.java | 6 +- .../indexing/compact/ReindexingConfigBuilder.java | 280 ++++ .../compact/ReindexingConfigOptimizer.java | 55 + .../compact/ReindexingDeletionRuleOptimizer.java | 251 +++ ...mentGranularityTimelineValidationException.java | 81 + .../task/ClientCompactionTaskQuerySerdeTest.java | 2 +- .../common/task/CompactionTaskParallelRunTest.java | 8 +- .../common/task/CompactionTaskRunBase.java | 4 +- .../indexing/common/task/CompactionTaskTest.java | 18 +- .../common/task/NativeCompactionRunnerTest.java | 118 ++ .../AbstractMultiPhaseParallelIndexingTest.java | 2 +- .../compact/CascadingReindexingTemplateTest.java | 1653 ++++++++++++++++++++ .../compact/ReindexingConfigBuilderTest.java | 327 ++++ .../ReindexingDeletionRuleOptimizerTest.java | 539 +++++++ .../environment-configs/router-custom-check-tls | 1 - .../tls/generate-client-certs-and-keystores.sh | 24 +- .../docker/tls/generate-root-certs.sh | 16 +- .../tls/generate-server-certs-and-keystores.sh | 30 +- integration-tests/docker/tls/root.cnf | 2 +- integration-tests/docker/tls/root2.cnf | 2 +- integration-tests/pom.xml | 5 - .../org.apache.druid.initialization.DruidModule | 16 - .../java/org/apache/druid/tests/TestNGGroup.java | 4 - .../org/apache/druid/tests/security/ITTLSTest.java | 552 ------- .../msq/dart/controller/ControllerHolder.java | 188 ++- .../msq/dart/controller/ControllerThreadPool.java | 52 + .../msq/dart/controller/sql/DartQueryMaker.java | 541 ++----- .../msq/dart/controller/sql/DartSqlEngine.java | 37 +- .../druid/msq/dart/guice/DartControllerModule.java | 18 + .../druid/msq/exec/CaptureReportQueryListener.java | 24 +- .../org/apache/druid/msq/exec/ControllerImpl.java | 3 - .../msq/exec/ControllerQueryResultsReader.java | 64 +- .../org/apache/druid/msq/exec/QueryListener.java | 26 +- .../druid/msq/exec/SequenceQueryListener.java | 122 ++ .../druid/msq/indexing/MSQCompactionRunner.java | 14 +- .../druid/msq/indexing/MSQControllerTask.java | 5 +- .../msq/indexing/TaskReportQueryListener.java | 99 +- .../druid/msq/input/RegularLoadableSegment.java | 12 +- .../druid/msq/util/SqlStatementResourceHelper.java | 18 +- .../dart/controller/http/DartSqlResourceTest.java | 63 +- .../druid/msq/exec/MSQCompactionTaskRunTest.java | 9 +- .../org/apache/druid/msq/exec/MSQReplaceTest.java | 25 +- .../msq/indexing/MSQCompactionRunnerTest.java | 2 +- .../msq/indexing/TaskReportQueryListenerTest.java | 112 +- .../input/table/DataSegmentWithLocationTest.java | 19 +- .../msq/test/MSQTestOverlordServiceClient.java | 49 +- .../apache/druid/msq/test/NoopQueryListener.java | 11 +- .../frame/channel/BlockingQueueFrameChannel.java | 2 + .../druid/frame/channel/FrameChannelSequence.java | 24 +- .../segment/transform/CompactionTransformSpec.java | 22 +- .../transform/CompactionTransformSpecTest.java | 81 +- .../apache/druid/timeline/CompactionStateTest.java | 10 +- .../org/apache/druid/timeline/DataSegmentTest.java | 60 +- .../druid/segment/loading/SegmentCacheManager.java | 9 +- .../segment/loading/SegmentLocalCacheManager.java | 6 +- .../org/apache/druid/server/SegmentManager.java | 14 +- .../server/compaction/AbstractReindexingRule.java | 162 ++ .../druid/server/compaction/CompactionStatus.java | 26 +- .../ComposingReindexingRuleProvider.java | 239 +++ .../DataSourceCompactibleSegmentIterator.java | 2 +- .../compaction/InlineReindexingRuleProvider.java | 334 ++++ .../server/compaction/IntervalGranularityInfo.java | 95 ++ .../compaction/ReindexingDataSchemaRule.java | 163 ++ .../server/compaction/ReindexingDeletionRule.java | 159 ++ .../server/compaction/ReindexingIOConfigRule.java | 109 ++ .../druid/server/compaction/ReindexingRule.java | 87 ++ .../server/compaction/ReindexingRuleProvider.java | 188 +++ .../ReindexingSegmentGranularityRule.java | 128 ++ .../compaction/ReindexingTuningConfigRule.java | 118 ++ .../InlineSchemaDataSourceCompactionConfig.java | 51 + .../segment/loading/NoopSegmentCacheManager.java | 3 +- .../SegmentLocalCacheManagerConcurrencyTest.java | 2 +- .../loading/SegmentLocalCacheManagerTest.java | 12 +- .../compaction/AbstractReindexingRuleTest.java | 62 + .../server/compaction/CompactionStatusTest.java | 107 ++ .../ComposingReindexingRuleProviderTest.java | 503 ++++++ .../InlineReindexingRuleProviderTest.java | 279 ++++ .../compaction/NewestSegmentFirstPolicyTest.java | 10 +- .../compaction/ReindexingDataSchemaRuleTest.java | 370 +++++ .../compaction/ReindexingDeletionRuleTest.java | 370 +++++ .../compaction/ReindexingIOConfigRuleTest.java | 172 ++ .../ReindexingSegmentGranularityRuleTest.java | 220 +++ .../compaction/ReindexingTuningConfigRuleTest.java | 196 +++ .../coordination/LoadableDataSegmentTest.java | 31 +- .../coordination/SegmentLoadDropHandlerTest.java | 4 +- ...InlineSchemaDataSourceCompactionConfigTest.java | 32 +- .../coordinator/duty/CompactSegmentsTest.java | 3 +- .../druid/server/http/DataSegmentPlusTest.java | 20 +- .../druid/test/utils/TestSegmentCacheManager.java | 36 +- .../embedded/junit5/EmbeddedClusterTestBase.java | 13 + 108 files changed, 10529 insertions(+), 1487 deletions(-) --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
