This is an automated email from the ASF dual-hosted git repository.
abhishekrb pushed a change to branch partial_results_missing_seg_fix
in repository https://gitbox.apache.org/repos/asf/druid.git
from 61157f10933 Revert "Revert "Revert "Revert the fix temporarily to
verify IT failure"""
add 24ec0b01db7 fix nvl vector processor failing with NPE if all null
inputs (#18024)
add b6daa632d8c fix SET statements apearing in JSON queries (#18026)
add b9c6fdc12c3 Add more concurrency unit tests for TaskQueue (#18022)
add 2ed53eda995 Fix class loading issue for glue catalog (#18016)
add 9bb25e6de92 fix OR filter partial index value matcher on cursor reset
(#18029)
add a063460da17 Fix typo in ChannelResourceFactory log (#18030)
add 2b1f1fc61dc Fix race condition in TaskQueue.removeTaskInternal (#18031)
add 8e55eb5c098 Add taskType dimension to task count metrics (#18032)
add 472411ae432 Update docs to include taskType for Overlord task count
metrics (#18035)
add 6974d5a14af Fix typo in GroupBy doc (#18038)
add c5cf2ac084b Use concurrent locks for multiple appends (#18041)
add 4ff4eea3113 Fix usage of compaction supervisor when
enableInputSourceSecurity is true (#18043)
add 6e507a62d0a Info logging for failures for cancellation (#18046)
add d99dfd5555e overhaul segment reference counting and segment map
function (#18005)
add 8232fb519d2 Web console: fix supervisor actions menu not working well
with lots of incremental loading (#18023)
add da0055d6e37 fix issue with numeric vector selectors on json_value when
least restrictive type contains arrays (#18053)
add d72b3bf0ea9 Raw SQL Support on HTTP endpoints (#17937)
add da45edac908 acquire segment references in bulk for ServerManager to
simplify reference handling (#18054)
add 88fec4b6abb Fix incorrect FixedBucketsHistogram counts when merging
indexes (#18049)
add 2e4f80abf82 add error column to the tasks view (#18057)
add 187d3fa7c4f Wrap populateResults() method to prevent query from
failing (#18044)
add 69b2e809002 Dart resource deprecation (#18003)
add 72c9f0c2d68 fix bug in NestedComplexColumn.getFieldLogicalType when
handling array element paths (#18059)
add 4d6076cf5df Switch to counter for tracking used task slots on
ForkingTaskRunner (#18045)
add 092c04b6f63 Quidem stabilization fixes (#18062)
add 1b8cc28be22 Fix flaky test in TaskQueueConcurrencyTest (#18066)
add 8115a8b63ad Associate NotYetSupported reasons with scopes (#18034)
add 3be94a09d81 Add embedded kill tasks that run on the Overlord (#18028)
add c89aeb44e31 Web console: allow freeform tier editing in retention
rules (#18050)
add f03a961c6f0 Update aws.sdk.version (#18068)
add 5f05c2a503e Fix IT failure (#18067)
add 454c47a0335 web-console fixes to work with latest dart changes (#18073)
add e9f351876e3 Merge branch 'master' into partial_results_missing_seg_fix
add ee115928c81 Address review comments.
add 6fbff4b0f18 Add only validateAndWriteHeader() & commentary for the test
No new revisions were added by this update.
Summary of changes:
.../benchmark/IndexedTableJoinCursorBenchmark.java | 7 +-
.../druid/benchmark/JoinAndLookupBenchmark.java | 22 +-
docs/api-reference/sql-api.md | 38 +-
docs/operations/metrics.md | 10 +-
docs/querying/groupbyquery.md | 4 +-
docs/querying/nested-columns.md | 10 +-
docs/querying/sql-functions.md | 6 +-
docs/querying/sql-json-functions.md | 4 +-
.../druid/iceberg/input/GlueIcebergCatalog.java | 19 +-
.../histogram/FixedBucketsHistogram.java | 16 +
.../FixedBucketsHistogramAggregatorFactory.java | 4 +-
.../FixedBucketsHistogramAggregationTest.java | 46 +-
.../druid/indexing/kafka/KafkaIndexTask.java | 18 +-
.../druid/indexing/kafka/KafkaSamplerSpec.java | 9 +-
.../kafka/supervisor/KafkaSupervisorSpec.java | 10 +-
.../druid/indexing/kinesis/KinesisIndexTask.java | 14 +-
.../druid/indexing/kinesis/KinesisSamplerSpec.java | 9 +-
.../kinesis/supervisor/KinesisSupervisorSpec.java | 10 +-
extensions-core/multi-stage-query/pom.xml | 5 +
.../msq/dart/DartResourcePermissionMapper.java | 6 +-
.../msq/dart/controller/http/DartQueryInfo.java | 4 +-
.../msq/dart/controller/http/DartSqlResource.java | 269 -------
.../msq/dart/controller/sql/DartSqlClient.java | 8 +-
.../controller/sql/DartSqlClientFactoryImpl.java | 4 +-
.../msq/dart/controller/sql/DartSqlClientImpl.java | 29 +-
.../msq/dart/controller/sql/DartSqlClients.java | 4 +-
.../msq/dart/controller/sql/DartSqlEngine.java | 118 ++-
.../druid/msq/dart/guice/DartControllerModule.java | 28 +-
.../druid/msq/dart/guice/DartWorkerModule.java | 19 +
.../msq/dart/worker/DartDataSegmentProvider.java | 27 +-
.../java/org/apache/druid/msq/exec/Controller.java | 5 +-
.../druid/msq/input/ParseExceptionUtils.java | 2 +-
.../druid/msq/querykit/BaseLeafFrameProcessor.java | 16 +-
.../querykit/BaseLeafFrameProcessorFactory.java | 17 +-
.../querykit/BaseLeafFrameProcessorManager.java | 7 +-
.../BroadcastJoinSegmentMapFnProcessor.java | 12 +-
.../querykit/RestrictedInputNumberDataSource.java | 8 +-
.../msq/querykit/SimpleSegmentMapFnProcessor.java | 10 +-
.../groupby/GroupByPreShuffleFrameProcessor.java | 9 +-
.../GroupByPreShuffleFrameProcessorFactory.java | 6 +-
.../msq/querykit/scan/ScanQueryFrameProcessor.java | 9 +-
.../scan/ScanQueryFrameProcessorFactory.java | 5 +-
.../org/apache/druid/msq/sql/MSQTaskSqlEngine.java | 15 +-
.../msq/sql/resources/SqlStatementResource.java | 13 +-
.../dart/controller/http/DartQueryInfoTest.java | 32 +
.../dart/controller/http/DartSqlResourceTest.java | 156 ++--
.../controller/http/GetQueriesResponseTest.java | 62 --
.../dart/controller/sql/DartSqlClientImplTest.java | 9 +-
.../druid/msq/exec/MSQComplexGroupByTest.java | 191 ++---
.../apache/druid/msq/exec/TestMSQSqlModule.java | 2 +-
.../querykit/scan/ScanQueryFrameProcessorTest.java | 6 +-
.../druid/msq/test/DartComponentSupplier.java | 4 +-
.../druid/msq/test/DecoupledCalciteDartTest.java | 6 +-
.../org/apache/druid/msq/test/MSQTestBase.java | 4 +-
.../druid/msq/test/MSQTestControllerContext.java | 2 +-
.../druid/msq/test/MSQTestWorkerContext.java | 4 +-
.../apache/druid/sql/avatica/DartDruidMeta.java | 2 +
.../org/apache/druid/sql/avatica/MSQDruidMeta.java | 2 +
.../druid/storage/s3/S3DataSegmentKiller.java | 2 +-
indexing-service/pom.xml | 5 +
.../indexing/common/TaskStorageDirTracker.java | 17 +
.../indexing/common/actions/SegmentNukeAction.java | 40 +-
.../indexing/common/task/HadoopIndexTask.java | 6 +-
.../druid/indexing/common/task/IndexTask.java | 5 +-
.../common/task/KillUnusedSegmentsTask.java | 73 +-
.../druid/indexing/common/task/TaskMetrics.java} | 20 +-
.../apache/druid/indexing/common/task/Tasks.java | 6 +
.../parallel/ParallelIndexSupervisorTask.java | 4 +-
.../parallel/PartialDimensionCardinalityTask.java | 6 +-
.../parallel/PartialDimensionDistributionTask.java | 6 +-
.../parallel/PartialHashSegmentGenerateTask.java | 6 +-
.../parallel/PartialRangeSegmentGenerateTask.java | 6 +-
.../task/batch/parallel/SinglePhaseSubTask.java | 5 +-
.../indexing/compact/CompactionSupervisorSpec.java | 12 +
.../druid/indexing/overlord/ForkingTaskRunner.java | 25 +-
.../druid/indexing/overlord/TaskLockbox.java | 15 +-
.../apache/druid/indexing/overlord/TaskMaster.java | 11 +-
.../apache/druid/indexing/overlord/TaskQueue.java | 78 +-
.../indexing/overlord/duty/KillTaskToolbox.java | 97 +++
.../overlord/duty/OverlordDutyExecutor.java | 11 +-
.../overlord/duty/UnusedSegmentsKiller.java | 477 +++++++++++
.../overlord/sampler/IndexTaskSamplerSpec.java | 6 +-
.../ScheduledBatchSupervisorSpec.java | 12 +
.../indexing/common/TaskStorageDirTrackerTest.java | 40 +
.../indexing/common/actions/TaskActionTestKit.java | 37 +-
.../indexing/common/task/IngestionTestBase.java | 4 +-
.../AbstractMultiPhaseParallelIndexingTest.java | 4 +-
.../parallel/SinglePhaseParallelIndexingTest.java | 4 +-
.../compact/CompactionSupervisorSpecTest.java | 11 +
.../overlord/TaskQueueConcurrencyTest.java | 213 ++++-
.../overlord/duty/OverlordDutyExecutorTest.java | 4 +-
.../overlord/duty/UnusedSegmentsKillerTest.java | 462 +++++++++++
.../ScheduledBatchSupervisorSpecTest.java | 17 +
.../TestIndexerMetadataStorageCoordinator.java | 32 +-
.../tools/ServerManagerForQueryErrorTest.java | 255 +++---
.../ServerManagerForQueryErrorTest.java | 286 ++++---
.../apache/druid/tests/query/ITSqlQueryTest.java | 319 ++++++++
.../security/AbstractAuthConfigurationTest.java | 10 +-
licenses.yaml | 4 +-
pom.xml | 2 +-
.../druid/indexer/report/KillTaskReport.java | 2 +-
.../http/client/pool/ChannelResourceFactory.java | 2 +-
.../expr/vector/VectorConditionalProcessors.java | 4 +
.../java/org/apache/druid/query/DataSource.java | 5 +-
.../org/apache/druid/query/FilteredDataSource.java | 9 +-
.../org/apache/druid/query/JoinDataSource.java | 86 +-
.../org/apache/druid/query/LeafDataSource.java | 7 +-
.../java/org/apache/druid/query/QueryContext.java | 9 +
.../java/org/apache/druid/query/QueryContexts.java | 3 +-
.../org/apache/druid/query/QueryDataSource.java | 5 +-
.../query/ReferenceCountingSegmentQueryRunner.java | 63 --
.../apache/druid/query/RestrictedDataSource.java | 8 +-
.../org/apache/druid/query/UnionDataSource.java | 7 +-
.../org/apache/druid/query/UnnestDataSource.java | 10 +-
.../apache/druid/query/lookup/LookupSegment.java | 2 +-
.../operator/SegmentToRowsAndColumnsOperator.java | 2 +-
.../druid/query/planning/ExecutionVertex.java | 25 +-
.../apache/druid/query/policy/PolicyEnforcer.java | 14 +-
.../apache/druid/query/scan/ScanQueryEngine.java | 2 +-
.../org/apache/druid/query/union/UnionQuery.java | 4 +-
.../druid/segment/BypassRestrictedSegment.java | 12 +-
.../druid/segment/DimensionDictionarySelector.java | 2 +-
.../org/apache/druid/segment/FilteredSegment.java | 10 +-
.../druid/segment/IncrementalIndexSegment.java | 6 +
.../druid/segment/QueryableIndexSegment.java | 6 +
.../druid/segment/ReferenceCountedObject.java | 46 --
.../segment/ReferenceCountedObjectProvider.java | 50 ++
.../segment/ReferenceCountedSegmentProvider.java | 296 +++++++
.../segment/ReferenceCountingCloseableObject.java | 2 +-
.../druid/segment/ReferenceCountingSegment.java | 202 -----
.../apache/druid/segment/RestrictedSegment.java | 28 +-
.../java/org/apache/druid/segment/Segment.java | 23 +-
.../apache/druid/segment/SegmentMapFunction.java | 49 ++
.../org/apache/druid/segment/SegmentReference.java | 49 --
.../org/apache/druid/segment/UnnestSegment.java | 10 +-
...edSegmentReference.java => WrappedSegment.java} | 24 +-
.../druid/segment/filter/ExpressionFilter.java | 32 +-
.../org/apache/druid/segment/filter/OrFilter.java | 71 +-
.../apache/druid/segment/join/HashJoinSegment.java | 56 +-
.../org/apache/druid/segment/join/Joinable.java | 6 +-
.../apache/druid/segment/join/JoinableClause.java | 8 +-
.../druid/segment/join/lookup/LookupJoinable.java | 2 +-
.../join/table/BroadcastSegmentIndexedTable.java | 7 +-
.../segment/join/table/FrameBasedIndexedTable.java | 2 +-
.../druid/segment/join/table/IndexedTable.java | 4 +-
.../segment/join/table/IndexedTableJoinable.java | 4 +-
...a => ReferenceCountedIndexedTableProvider.java} | 6 +-
.../segment/join/table/RowBasedIndexedTable.java | 2 +-
...oadingException.java => SegmentKillResult.java} | 31 +-
.../nested/CompressedNestedDataComplexColumn.java | 45 +-
.../segment/nested/NestedDataComplexColumn.java | 9 +-
.../segment/virtual/NestedFieldVirtualColumn.java | 32 +-
.../RowBasedExpressionColumnValueSelector.java | 24 +-
.../apache/druid/error/DruidExceptionMatcher.java | 8 +-
.../druid/java/util/metrics/MetricsVerifier.java | 36 +-
.../druid/math/expr/VectorExprSanityTest.java | 3 +-
.../apache/druid/query/QueryRunnerTestHelper.java | 56 +-
.../groupby/UnnestGroupByQueryRunnerTest.java | 2 +-
.../druid/query/lookup/LookupSegmentTest.java | 4 +-
.../druid/query/policy/NoopPolicyEnforcerTest.java | 4 +-
.../RestrictAllTablesPolicyEnforcerTest.java | 24 +-
.../druid/query/scan/NestedDataScanQueryTest.java | 2 +-
.../timeboundary/TimeBoundaryQueryRunnerTest.java | 8 +-
.../segment/ReferenceCountingSegmentTest.java | 32 +-
.../druid/segment/filter/BaseFilterTest.java | 25 +
.../druid/segment/filter/ExpressionFilterTest.java | 17 +
.../apache/druid/segment/filter/OrFilterTest.java | 40 +
.../join/BaseHashJoinSegmentCursorFactoryTest.java | 7 +-
.../join/HashJoinSegmentCursorFactoryTest.java | 32 +-
.../druid/segment/join/HashJoinSegmentTest.java | 208 ++---
.../apache/druid/segment/join/NoopDataSource.java | 7 +-
.../druid/segment/join/PostJoinCursorTest.java | 7 +-
.../nested/NestedDataColumnSupplierTest.java | 23 +-
.../nested/NestedDataColumnSupplierV4Test.java | 10 +-
.../test/resources/nested-all-types-test-data.json | 14 +-
.../IndexerMetadataStorageCoordinator.java | 36 +-
.../overlord/supervisor/SupervisorSpec.java | 9 +-
.../IndexerSQLMetadataStorageCoordinator.java | 41 +-
.../metadata/SegmentsMetadataManagerConfig.java | 23 +-
.../druid/metadata/SqlSegmentsMetadataQuery.java | 119 ++-
.../UnusedSegmentKillerConfig.java} | 43 +-
.../segment/CachedSegmentMetadataTransaction.java | 7 +
.../segment/SegmentMetadataReadTransaction.java | 6 +
.../segment/SqlSegmentMetadataTransaction.java | 6 +
.../druid/query/ResultLevelCachingQueryRunner.java | 33 +-
.../join/BroadcastTableJoinableFactory.java | 6 +-
.../druid/segment/loading/SegmentCacheManager.java | 14 +-
.../segment/loading/SegmentLocalCacheManager.java | 10 +-
.../apache/druid/segment/realtime/FireHydrant.java | 96 +--
.../realtime/appenderator/BatchAppenderator.java | 9 +-
.../appenderator/SinkQuerySegmentWalker.java | 8 +-
.../realtime/appenderator/StreamAppenderator.java | 9 +-
.../apache/druid/segment/realtime/sink/Sink.java | 49 +-
.../realtime/sink/SinkSegmentReference.java | 12 +-
.../druid/server/LocalQuerySegmentWalker.java | 17 +-
.../org/apache/druid/server/QueryResultPusher.java | 79 +-
.../org/apache/druid/server/SegmentManager.java | 217 ++---
.../druid/server/coordination/ServerManager.java | 343 +++++---
.../coordinator/duty/KillUnusedSegments.java | 8 +-
.../druid/server/coordinator/stats/Dimension.java | 1 +
...BadRequestException.java => HttpException.java} | 30 +-
...ceptionMapper.java => HttpExceptionMapper.java} | 9 +-
.../initialization/jetty/JettyServerModule.java | 1 +
.../server/metrics/TaskCountStatsMonitor.java | 6 +-
.../server/metrics/TaskCountStatsProvider.java | 21 +-
.../apache/druid/server/security/AuthConfig.java | 2 +-
.../druid/server/security/AuthorizationUtils.java | 12 +
.../druid/discovery/DataServerClientTest.java | 20 +
.../apache/druid/discovery/DataServerResponse.java | 43 -
.../overlord/supervisor/SupervisorSpecTest.java | 13 +-
...rSQLMetadataStorageCoordinatorReadOnlyTest.java | 2 +-
.../IndexerSQLMetadataStorageCoordinatorTest.java | 101 ++-
.../SqlSegmentsMetadataManagerProviderTest.java | 2 +-
.../SqlSegmentsMetadataManagerSchemaPollTest.java | 4 +-
.../metadata/SqlSegmentsMetadataManagerTest.java | 3 +-
.../SqlSegmentsMetadataManagerTestBase.java | 2 +-
.../segment/SqlSegmentsMetadataManagerV2Test.java | 2 +-
.../cache/HeapMemorySegmentMetadataCacheTest.java | 2 +-
.../query/ResultLevelCachingQueryRunnerTest.java | 22 +
.../segment/loading/NoopSegmentCacheManager.java | 6 +-
.../loading/SegmentLocalCacheManagerTest.java | 20 +-
.../CoordinatorSegmentMetadataCacheTest.java | 2 +-
.../druid/segment/realtime/FireHydrantTest.java | 138 +---
.../druid/segment/realtime/sink/SinkTest.java | 10 +-
.../druid/server/ClientQuerySegmentWalkerTest.java | 10 +-
.../org/apache/druid/server/QueryResourceTest.java | 7 +-
.../org/apache/druid/server/QueryStackTests.java | 4 +-
.../apache/druid/server/SegmentManagerTest.java | 8 +-
.../server/SpecificSegmentsQuerySegmentWalker.java | 14 +-
.../server/TestClusterQuerySegmentWalker.java | 99 ++-
.../server/coordination/ServerManagerTest.java | 100 ++-
.../simulate/TestDruidLeaderSelector.java | 11 +-
.../server/metrics/TaskCountStatsMonitorTest.java | 47 +-
.../druid/test/utils/TestSegmentCacheManager.java | 12 +-
services/pom.xml | 4 +
.../java/org/apache/druid/cli/CliOverlord.java | 9 +-
.../main/java/org/apache/druid/cli/CliPeon.java | 9 +-
.../java/org/apache/druid/cli/DumpSegment.java | 4 +-
.../druid/server/AsyncQueryForwardingServlet.java | 28 +-
.../server/AsyncQueryForwardingServletTest.java | 2 +-
sql/pom.xml | 13 +-
.../java/org/apache/druid/sql/DirectStatement.java | 11 +-
.../calcite/external/DruidExternTableMacro.java | 8 +-
.../external/SchemaAwareUserDefinedTableMacro.java | 7 +-
.../druid/sql/calcite/run/NativeSqlEngine.java | 44 +-
.../apache/druid/sql/calcite/run/SqlEngine.java | 35 +
.../druid/sql/calcite/view/ViewSqlEngine.java | 8 +
.../java/org/apache/druid/sql/guice/SqlModule.java | 8 +
.../java/org/apache/druid/sql/http/EngineInfo.java | 31 +-
.../apache/druid/sql}/http/GetQueriesResponse.java | 10 +-
.../java/org/apache/druid/sql/http/QueryInfo.java | 8 +-
.../apache/druid/sql/http/SqlEngineRegistry.java | 63 ++
.../org/apache/druid/sql/http/SqlHttpModule.java | 3 +
.../java/org/apache/druid/sql/http/SqlQuery.java | 144 ++++
.../org/apache/druid/sql/http/SqlResource.java | 99 ++-
.../druid/sql/http/SupportedEnginesResponse.java | 22 +-
.../druid/sql/calcite/BaseCalciteQueryTest.java | 3 +-
.../sql/calcite/CalciteNestedDataQueryTest.java | 135 +++-
.../sql/calcite/CalciteScanSignatureTest.java | 7 +
.../druid/sql/calcite/CalciteSysQueryTest.java | 6 +-
.../druid/sql/calcite/DecoupledExtension.java | 1 -
.../DecoupledPlanningCalciteArraysQueryTest.java | 6 +-
...ecoupledPlanningCalciteCorrelatedQueryTest.java | 5 +-
.../DecoupledPlanningCalciteJoinQueryTest.java | 5 +-
...ecoupledPlanningCalciteNestedDataQueryTest.java | 5 +-
.../calcite/DecoupledPlanningCalciteQueryTest.java | 5 +-
.../DecoupledPlanningCalciteUnionQueryTest.java | 5 +-
.../druid/sql/calcite/DrillWindowQueryTest.java | 3 +-
.../druid/sql/calcite/IngestionTestSqlEngine.java | 7 +
.../apache/druid/sql/calcite/NotYetSupported.java | 83 +-
.../calcite/planner/CalcitePlannerModuleTest.java | 7 +-
.../druid/sql/calcite/util/CalciteTests.java | 14 +-
.../druid/sql/http/GetQueriesResponseTest.java | 140 ++++
.../apache/druid/sql/http/SqlHttpModuleTest.java | 2 +-
.../org/apache/druid/sql/http/SqlResourceTest.java | 47 +-
web-console/.gitignore | 1 +
web-console/package-lock.json | 14 +-
web-console/package.json | 3 +-
.../__snapshots__/rule-editor.spec.tsx.snap | 410 +++++-----
.../__snapshots__/tiered-replicant.spec.tsx.snap | 879 +++++++++++++++++++++
.../src/components/rule-editor/rule-editor.tsx | 89 +--
.../rule-editor/tiered-replicant.spec.tsx | 108 +++
.../components/rule-editor/tiered-replicant.tsx | 76 ++
.../__snapshots__/suggestion-menu.spec.tsx.snap | 27 +-
.../suggestion-menu/suggestion-menu.spec.tsx | 9 +-
.../components/suggestion-menu/suggestion-menu.tsx | 1 +
.../table-filterable-cell.tsx | 13 +-
web-console/src/console-application.tsx | 2 +-
.../__snapshots__/history-dialog.spec.tsx.snap | 6 +-
.../dialogs/history-dialog/history-dialog.spec.tsx | 4 +-
.../src/dialogs/history-dialog/history-dialog.tsx | 5 +-
.../__snapshots__/retention-dialog.spec.tsx.snap | 148 ++--
.../src/dialogs/status-dialog/status-dialog.tsx | 4 +-
.../src/druid-models/dart/dart-query-entry.mock.ts | 3 +
.../src/druid-models/dart/dart-query-entry.ts | 1 +
.../src/druid-models/load-rule/load-rule.spec.ts | 502 ++++++++++++
.../src/druid-models/load-rule/load-rule.ts | 7 +-
.../workbench-query/workbench-query.spec.ts | 217 +++++
.../workbench-query/workbench-query.ts | 15 +-
web-console/src/helpers/capabilities.ts | 7 +-
.../src/react-table/react-table-filters.spec.ts | 8 +-
web-console/src/react-table/react-table-filters.ts | 13 +-
.../react-table-pagination.tsx | 4 +-
web-console/src/utils/druid-query.ts | 13 -
.../views/datasources-view/datasources-view.tsx | 10 +-
.../src/views/lookups-view/lookups-view.tsx | 4 +-
.../__snapshots__/segments-view.spec.tsx.snap | 2 +-
.../src/views/segments-view/segments-view.tsx | 84 +-
.../__snapshots__/services-view.spec.tsx.snap | 544 ++++++-------
.../fill-indicator/fill-indicator.scss} | 25 +-
.../fill-indicator/fill-indicator.tsx} | 23 +-
.../src/views/services-view/services-view.scss | 24 -
.../src/views/services-view/services-view.spec.tsx | 66 +-
.../src/views/services-view/services-view.tsx | 635 +++++++--------
.../__snapshots__/supervisors-view.spec.tsx.snap | 575 ++++++--------
.../views/supervisors-view/supervisors-view.tsx | 728 +++++++++--------
.../__snapshots__/tasks-view.spec.tsx.snap | 16 +-
web-console/src/views/tasks-view/tasks-view.tsx | 11 +
.../current-dart-panel/current-dart-panel.tsx | 7 +-
.../explain-dialog/explain-dialog.tsx | 6 +-
.../views/workbench-view/query-tab/query-tab.tsx | 4 +-
321 files changed, 9836 insertions(+), 4601 deletions(-)
delete mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/dart/controller/http/DartSqlResource.java
delete mode 100644
extensions-core/multi-stage-query/src/test/java/org/apache/druid/msq/dart/controller/http/GetQueriesResponseTest.java
copy
indexing-service/src/{test/java/org/apache/druid/indexing/common/task/NoopTaskTest.java
=> main/java/org/apache/druid/indexing/common/task/TaskMetrics.java} (63%)
create mode 100644
indexing-service/src/main/java/org/apache/druid/indexing/overlord/duty/KillTaskToolbox.java
create mode 100644
indexing-service/src/main/java/org/apache/druid/indexing/overlord/duty/UnusedSegmentsKiller.java
create mode 100644
indexing-service/src/test/java/org/apache/druid/indexing/overlord/duty/UnusedSegmentsKillerTest.java
create mode 100644
integration-tests/src/test/java/org/apache/druid/tests/query/ITSqlQueryTest.java
delete mode 100644
processing/src/main/java/org/apache/druid/query/ReferenceCountingSegmentQueryRunner.java
delete mode 100644
processing/src/main/java/org/apache/druid/segment/ReferenceCountedObject.java
create mode 100644
processing/src/main/java/org/apache/druid/segment/ReferenceCountedObjectProvider.java
create mode 100644
processing/src/main/java/org/apache/druid/segment/ReferenceCountedSegmentProvider.java
delete mode 100644
processing/src/main/java/org/apache/druid/segment/ReferenceCountingSegment.java
create mode 100644
processing/src/main/java/org/apache/druid/segment/SegmentMapFunction.java
delete mode 100644
processing/src/main/java/org/apache/druid/segment/SegmentReference.java
rename
processing/src/main/java/org/apache/druid/segment/{WrappedSegmentReference.java
=> WrappedSegment.java} (75%)
rename
processing/src/main/java/org/apache/druid/segment/join/table/{ReferenceCountingIndexedTable.java
=> ReferenceCountedIndexedTableProvider.java} (89%)
copy
processing/src/main/java/org/apache/druid/segment/loading/{SegmentLoadingException.java
=> SegmentKillResult.java} (63%)
copy
server/src/main/java/org/apache/druid/{server/coordinator/CoordinatorOverlordServiceConfig.java
=> metadata/UnusedSegmentKillerConfig.java} (57%)
copy
server/src/main/java/org/apache/druid/server/initialization/jetty/{BadRequestException.java
=> HttpException.java} (66%)
copy
server/src/main/java/org/apache/druid/server/initialization/jetty/{ForbiddenExceptionMapper.java
=> HttpExceptionMapper.java} (79%)
delete mode 100644
server/src/test/java/org/apache/druid/discovery/DataServerResponse.java
copy
processing/src/main/java/org/apache/druid/query/policy/NoopPolicyEnforcer.java
=> sql/src/main/java/org/apache/druid/sql/http/EngineInfo.java (72%)
rename
{extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/dart/controller
=> sql/src/main/java/org/apache/druid/sql}/http/GetQueriesResponse.java (83%)
copy server/src/main/java/org/apache/druid/segment/indexing/IOConfig.java =>
sql/src/main/java/org/apache/druid/sql/http/QueryInfo.java (86%)
create mode 100644
sql/src/main/java/org/apache/druid/sql/http/SqlEngineRegistry.java
copy
extensions-core/hdfs-storage/src/main/java/org/apache/druid/storage/hdfs/tasklog/HdfsTaskLogsConfig.java
=> sql/src/main/java/org/apache/druid/sql/http/SupportedEnginesResponse.java
(71%)
create mode 100644
sql/src/test/java/org/apache/druid/sql/http/GetQueriesResponseTest.java
create mode 100644
web-console/src/components/rule-editor/__snapshots__/tiered-replicant.spec.tsx.snap
create mode 100644
web-console/src/components/rule-editor/tiered-replicant.spec.tsx
create mode 100644 web-console/src/components/rule-editor/tiered-replicant.tsx
create mode 100644 web-console/src/druid-models/load-rule/load-rule.spec.ts
copy web-console/src/views/{lookups-view/lookups-view.scss =>
services-view/fill-indicator/fill-indicator.scss} (75%)
copy web-console/src/views/{explore-view/components/issue/issue.tsx =>
services-view/fill-indicator/fill-indicator.tsx} (65%)
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
