This is an automated email from the ASF dual-hosted git repository.
lakshsingla pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/druid.git
from cff5d1e3695 Add method Supervisor.computeLagForAutoScaler (#16314)
add b9bbde5c0a1 Fix deadlock that can occur while merging group by results
(#15420)
No new revisions were added by this update.
Summary of changes:
.../benchmark/GroupByTypeInterfaceBenchmark.java | 7 +-
.../query/CachingClusteredClientBenchmark.java | 9 +-
.../druid/benchmark/query/GroupByBenchmark.java | 7 +-
.../DistinctCountGroupByQueryTest.java | 4 +-
.../MaterializedViewQueryQueryToolChest.java | 25 ++-
.../MaterializedViewQueryQueryToolChestTest.java | 6 +-
.../druid/segment/MapVirtualColumnGroupByTest.java | 10 +-
.../ApproximateHistogramGroupByQueryTest.java | 6 +-
.../FixedBucketsHistogramGroupByQueryTest.java | 6 +-
.../apache/druid/testing/utils/ITRetryUtil.java | 9 +-
.../org/apache/druid/query/FluentQueryRunner.java | 9 +-
.../java/org/apache/druid/query/QueryContext.java | 4 +
.../java/org/apache/druid/query/QueryContexts.java | 4 +-
.../org/apache/druid/query/QueryResourceId.java | 119 +++++++++++
.../org/apache/druid/query/QueryToolChest.java | 24 +++
.../query/groupby/GroupByQueryQueryToolChest.java | 51 ++++-
.../druid/query/groupby/GroupByQueryResources.java | 119 +++++++++--
.../query/groupby/GroupByQueryRunnerFactory.java | 3 +
.../groupby/GroupByResourcesReservationPool.java | 141 +++++++++++++
.../apache/druid/query/groupby/GroupingEngine.java | 61 ++++--
.../epinephelinae/GroupByMergingQueryRunner.java | 78 ++++----
.../groupby/epinephelinae/GroupByQueryEngine.java | 3 +
.../groupby/epinephelinae/GroupByRowProcessor.java | 2 +-
.../apache/druid/query/QueryResourceIdTest.java | 27 ++-
.../apache/druid/query/QueryRunnerTestHelper.java | 4 +-
.../query/aggregation/AggregationTestHelper.java | 10 +-
.../druid/query/context/ResponseContextTest.java | 4 +-
...GroupByLimitPushDownInsufficientBufferTest.java | 83 +++++---
.../GroupByLimitPushDownMultiNodeMergeTest.java | 174 ++++++++++------
.../query/groupby/GroupByMultiSegmentTest.java | 17 +-
.../query/groupby/GroupByQueryMergeBufferTest.java | 25 ++-
.../groupby/GroupByQueryQueryToolChestTest.java | 110 +++++------
.../groupby/GroupByQueryRunnerFactoryTest.java | 15 +-
.../groupby/GroupByQueryRunnerFailureTest.java | 14 +-
.../query/groupby/GroupByQueryRunnerTest.java | 218 ++++++++++++++-------
.../groupby/GroupByQueryRunnerTestHelper.java | 22 ++-
.../groupby/GroupByTimeseriesQueryRunnerTest.java | 1 +
.../query/groupby/NestedQueryPushDownTest.java | 33 ++--
.../groupby/UnnestGroupByQueryRunnerTest.java | 7 +-
.../druid/query/search/SearchQueryRunnerTest.java | 2 +-
.../apache/druid/guice/BrokerProcessingModule.java | 13 ++
.../apache/druid/guice/DruidProcessingModule.java | 13 ++
.../apache/druid/guice/RouterProcessingModule.java | 16 ++
.../appenderator/SinkQuerySegmentWalker.java | 28 +--
.../druid/server/ClientQuerySegmentWalker.java | 43 +---
.../druid/server/LocalQuerySegmentWalker.java | 2 +-
.../druid/server/QuerySwappingQueryRunner.java | 62 ++++++
.../server/ResourceIdPopulatingQueryRunner.java | 57 +++---
.../druid/server/coordination/ServerManager.java | 36 ++--
.../druid/client/CachingClusteredClientTest.java | 2 +-
.../druid/discovery/DataServerClientTest.java | 2 +-
.../druid/server/ClientQuerySegmentWalkerTest.java | 61 ++++--
.../apache/druid/server/QuerySchedulerTest.java | 7 +-
.../org/apache/druid/server/QueryStackTests.java | 3 +-
.../server/SpecificSegmentsQuerySegmentWalker.java | 14 +-
.../server/TestClusterQuerySegmentWalker.java | 33 +++-
.../server/coordination/ServerManagerTest.java | 2 +-
.../java/org/apache/druid/cli/DumpSegment.java | 5 +-
.../java/org/apache/druid/cli/DumpSegmentTest.java | 2 +
.../druid/sql/calcite/util/TestDataBuilder.java | 4 +-
60 files changed, 1354 insertions(+), 524 deletions(-)
create mode 100644
processing/src/main/java/org/apache/druid/query/QueryResourceId.java
create mode 100644
processing/src/main/java/org/apache/druid/query/groupby/GroupByResourcesReservationPool.java
copy server/src/test/java/org/apache/druid/metadata/ReplaceTaskLockTest.java
=> processing/src/test/java/org/apache/druid/query/QueryResourceIdTest.java
(61%)
create mode 100644
server/src/main/java/org/apache/druid/server/QuerySwappingQueryRunner.java
copy
benchmarks/src/test/java/org/apache/druid/benchmark/query/SerializingQueryRunner.java
=>
server/src/main/java/org/apache/druid/server/ResourceIdPopulatingQueryRunner.java
(54%)
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
