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 47515cd9e4866691058215f79df33eb576aa984d Merge: 9abee83af10 87d978bf405 Author: Abhishek Balaji Radhakrishnan <[email protected]> AuthorDate: Thu Feb 26 17:24:49 2026 -0800 Merge branch 'master' into peon_server_priorities .github/workflows/ci.yml | 2 +- docs/api-reference/sql-api.md | 9 - docs/configuration/index.md | 2 +- docs/data-management/compaction.md | 2 +- docs/design/storage.md | 2 +- docs/ingestion/tasks.md | 2 +- embedded-tests/pom.xml | 31 + .../indexing/KafkaIndexDataFormatsTest.java | 76 ++ .../indexing/KafkaIndexFaultToleranceTest.java | 77 ++ ...ryResource.java => SchemaRegistryResource.java} | 11 +- ...st.java => StreamIndexDataFormatsTestBase.java} | 214 ++-- ...est.java => StreamIndexFaultToleranceTest.java} | 38 +- ...KafkaTestBase.java => StreamIndexTestBase.java} | 68 +- .../CostBasedAutoScalerIntegrationTest.java | 4 +- .../embedded/kinesis/KinesisDataFormatsTest.java | 114 ++ .../kinesis/KinesisFaultToleranceTest.java | 115 ++ .../testing/embedded/kinesis/KinesisResource.java | 239 ++++ ...CentralizedSchemaMetadataQueryDisabledTest.java | 4 +- .../CentralizedSchemaPublishFailureTest.java | 4 +- .../testing/embedded/server/FaultyClusterTest.java | 18 +- .../embedded/server/KafkaMultiSupervisorTest.java | 18 +- .../indexing/kafka/simulate/KafkaResource.java | 41 +- .../druid/indexing/common/LockGranularity.java | 4 + .../druid/indexing/compact/CompactionJobQueue.java | 10 +- .../autoscaler/WeightedCostFunction.java | 6 +- .../autoscaler/WeightedCostFunctionTest.java | 4 +- integration-tests-ex/tools/pom.xml | 13 - .../druid/testing/tools/KinesisEventWriter.java | 119 -- .../environment-configs/override-examples/kinesis | 22 - integration-tests/pom.xml | 16 - .../druid/testing/utils/DataLoaderHelper.java | 60 - .../druid/testing/utils/KinesisAdminClient.java | 207 ---- .../java/org/apache/druid/tests/TestNGGroup.java | 16 - .../druid/tests/indexer/AbstractIndexerTest.java | 3 - ...tractKinesisIndexingServiceEmptyShardsTest.java | 45 - .../AbstractKinesisIndexingServiceTest.java | 220 ---- .../tests/indexer/AbstractStreamIndexingTest.java | 1233 -------------------- ...isIndexingServiceEmptyShardsSerializedTest.java | 74 -- .../ITKinesisIndexingServiceSerializedTest.java | 97 -- .../ITKinesisIndexingServiceDataFormatTest.java | 96 -- .../ITKinesisIndexingServiceParallelizedTest.java | 67 -- .../dart/controller/DartTableInputSpecSlicer.java | 30 +- .../druid/msq/dart/guice/DartControllerModule.java | 28 +- .../org/apache/druid/msq/exec/ControllerImpl.java | 49 +- .../org/apache/druid/msq/exec/StageProcessor.java | 12 + .../msq/indexing/IndexerTableInputSpecSlicer.java | 26 +- .../druid/msq/indexing/error/MSQErrorReport.java | 8 + .../org/apache/druid/msq/input/InputSlice.java | 2 +- .../apache/druid/msq/input/InputSpecSlicer.java | 15 +- .../apache/druid/msq/input/MapInputSpecSlicer.java | 9 +- .../input/external/ExternalInputSpecSlicer.java | 9 +- .../msq/input/inline/InlineInputSpecSlicer.java | 5 +- .../msq/input/lookup/LookupInputSpecSlicer.java | 5 +- .../msq/input/stage/StageInputSpecSlicer.java | 5 +- .../druid/msq/input/table/TableInputSpec.java | 59 +- .../apache/druid/msq/kernel/StageDefinition.java | 11 + .../druid/msq/kernel/WorkerAssignmentStrategy.java | 10 +- .../druid/msq/kernel/controller/WorkerInputs.java | 5 +- .../apache/druid/msq/logical/stages/ReadStage.java | 2 +- .../druid/msq/querykit/BaseLeafStageProcessor.java | 17 +- .../apache/druid/msq/querykit/DataSourcePlan.java | 53 +- .../druid/msq/querykit/WindowOperatorQueryKit.java | 2 - .../msq/querykit/groupby/GroupByQueryKit.java | 2 - .../druid/msq/querykit/scan/ScanQueryKit.java | 2 - .../controller/DartTableInputSpecSlicerTest.java | 35 +- .../org/apache/druid/msq/input/InputSpecsTest.java | 12 +- .../external/ExternalInputSpecSlicerTest.java | 28 +- .../msq/input/stage/StageInputSpecSlicerTest.java | 8 +- .../table/IndexerTableInputSpecSlicerTest.java | 81 +- .../druid/msq/input/table/TableInputSpecTest.java | 43 +- .../controller/ControllerTestInputSpecSlicer.java | 5 +- .../msq/kernel/controller/WorkerInputsTest.java | 9 +- .../msq1.iq | 9 +- .../msqJoinHint.iq | 27 +- .../msqNestedJoinHint.iq | 9 +- .../apache/druid/query/filter/DimFilterUtils.java | 95 -- .../druid/query/filter/FilterSegmentPruner.java | 136 +++ .../apache/druid/query/filter/SegmentPruner.java | 19 +- .../druid/query/planning/ExecutionVertex.java | 304 ++--- .../partition/NumberedOverwriteShardSpec.java | 7 +- .../druid/query/filter/DimFilterUtilsTest.java | 126 -- .../query/filter/FilterSegmentPrunerTest.java | 126 ++ .../qaWin/sql_explain.msq.iq | 36 +- .../druid/client/CachingClusteredClient.java | 30 +- .../selector/CustomTierSelectorStrategy.java | 21 +- .../CompactionCandidateSearchPolicy.java | 27 +- .../druid/server/compaction/CompactionMode.java | 27 +- .../server/compaction/CompactionRunSimulator.java | 5 + .../server/compaction/CompactionStatusTracker.java | 6 + .../testing/embedded/StreamIngestResource.java | 43 + .../testing/embedded/TestcontainerResource.java | 12 +- web-console/src/druid-models/stages/stages.mock.ts | 7 - web-console/src/druid-models/stages/stages.ts | 2 - .../execution-stages-pane.tsx | 2 - 94 files changed, 1741 insertions(+), 3325 deletions(-) --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
