This is an automated email from the ASF dual-hosted git repository.
karan pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/druid.git
from b20de6924e2 Revert "Fix error where communication failures to k8s can
lead to stuck tasks (#17431)" (#17747)
add 592d2e05b3a Fix JoinDataSource to not ignore DataSource layers
silently (#17726)
No new revisions were added by this update.
Summary of changes:
.../querykit/BaseLeafFrameProcessorFactory.java | 2 +-
.../apache/druid/msq/querykit/DataSourcePlan.java | 2 +-
.../druid/msq/querykit/InputNumberDataSource.java | 2 +-
.../querykit/RestrictedInputNumberDataSource.java | 2 +-
.../java/org/apache/druid/query/BaseQuery.java | 21 +-
.../java/org/apache/druid/query/DataSource.java | 4 -
.../main/java/org/apache/druid/query/Druids.java | 5 +
.../druid/query/FrameBasedInlineDataSource.java | 2 +-
.../org/apache/druid/query/InlineDataSource.java | 2 +-
.../org/apache/druid/query/JoinDataSource.java | 260 +++++++++------------
.../org/apache/druid/query/LookupDataSource.java | 2 +-
.../main/java/org/apache/druid/query/Queries.java | 23 +-
.../main/java/org/apache/druid/query/Query.java | 14 +-
.../org/apache/druid/query/QueryDataSource.java | 9 +-
.../org/apache/druid/query/TableDataSource.java | 2 +-
.../org/apache/druid/query/UnionDataSource.java | 2 +-
.../druid/query/UnionDataSourceQueryRunner.java | 2 +-
.../org/apache/druid/query/UnnestDataSource.java | 8 +-
.../org/apache/druid/query/filter/DimFilters.java | 19 ++
.../apache/druid/query/groupby/GroupByQuery.java | 10 +
.../druid/query/planning/DataSourceAnalysis.java | 62 ++---
.../druid/query/planning/PreJoinableClause.java | 36 ++-
.../org/apache/druid/query/union/UnionQuery.java | 2 +-
.../org/apache/druid/segment/filter/Filters.java | 14 ++
.../apache/druid/query/FilteredDataSourceTest.java | 15 +-
.../java/org/apache/druid/query/QueriesTest.java | 2 +-
.../query/planning/DataSourceAnalysisTest.java | 244 ++++++++++++-------
.../query/planning/PreJoinableClauseTest.java | 30 ++-
.../apache/druid/segment/join/NoopDataSource.java | 2 +-
.../druid/client/CachingClusteredClient.java | 9 +-
.../druid/server/LocalQuerySegmentWalker.java | 2 +-
.../druid/server/coordination/ServerManager.java | 2 +-
.../client/CachingClusteredClientPerfTest.java | 5 +-
.../server/coordination/ServerManagerTest.java | 23 +-
.../sql/calcite/external/ExternalDataSource.java | 6 +-
.../apache/druid/sql/calcite/rel/DruidQuery.java | 4 +-
.../druid/sql/calcite/run/NativeQueryMaker.java | 8 +-
.../druid/sql/calcite/CalciteJoinQueryTest.java | 91 +++-----
.../apache/druid/sql/calcite/NotYetSupported.java | 6 +
39 files changed, 537 insertions(+), 419 deletions(-)
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
