This is an automated email from the ASF dual-hosted git repository.
xiangfu0 pushed a change to branch xiangfu0/agg-rewrite/04-any-value
in repository https://gitbox.apache.org/repos/asf/pinot.git
omit d24baacb05c Clarify ANY_VALUE explicit type errors and engine semantics
omit 4891838b75a Skip evaluating ANY_VALUE input for all-null blocks
omit a8ab4e2b473 Read ANY_VALUE values as the plan types and once per block
omit 5cf721fe14d Merge remote-tracking branch 'origin/master' into
xiangfu0/agg-rewrite/04-any-value
omit e1278625f0e Default the ANY_VALUE data type inference to off
omit 4fe27fc1f9f Keep the FIRST/LAST_WITH_TIME data type mapping for the
ANY_VALUE rewrite
omit 921fee07970 Return the input's logical type from ANY_VALUE
add bff525d98ea Keep source nulls when deriving a column at segment load
(#19955)
add c5b8107fa6a Return the cause chain when an /ingestFromFile record
fails (#19716)
add efffb312091 Bump org.webjars:swagger-ui from 5.33.2 to 5.34.0 (#20045)
add 332a350000e Bump org.apache.pulsar:pulsar-bom from 5.0.0 to 5.0.1
(#20046)
add 8ab072694fe Bump reactor-netty.version from 1.3.7 to 1.3.8 (#20047)
add 452de38982a Bump com.gradle:develocity-maven-extension from 2.6.0 to
2.6.1 (#20049)
add 531bcd02591 Bump com.github.jnr:jnr-posix from 3.2.4 to 3.2.5 (#20053)
add 93978b69b20 Bump software.amazon.awssdk:bom from 2.57.0 to 2.57.3
(#20050)
add 2fd3001a330 Bump com.github.jnr:jnr-ffi from 2.3.3 to 2.3.4 (#20051)
add 960190cbe91 Bump at.yawk.lz4:lz4-java from 1.12.0 to 1.12.1 (#20052)
add 7e772548357 Bump actions/setup-python from 7.0.0 to 7.1.0 (#20055)
add c051ac7643b Bump docker/login-action from 4.6.0 to 4.7.0 (#20056)
add 9c48dac9d7b Close the posting list stream in OffHeapJsonIndexCreator
(#19925)
add 401528f2cc2 Bump io.projectreactor:reactor-core from 3.8.7 to 3.8.8
(#20054)
add d085f946779 Recover unhealthy MSE workers that are not servers in the
routing manager (#20005)
add 32bc2ee2da7 Prebuild Lucene doc ID mappings from numeric doc values
(#19897)
add 19dec509431 Reject the join distribution types that answer the join
wrong (#19862)
add 9c8b2901d3e Require consecutive readiness checks in the
integration-test base (#20015)
add 7835c7dc378 Support MODE on STRING, BOOLEAN and TIMESTAMP inputs
(#19991)
add e952429935e Return the input logical type from ANY_VALUE with an
opt-in rewrite
This update added new revisions after undoing existing revisions.
That is to say, some revisions that were in the old version of the
branch are not in the new version. This situation occurs
when a user --force pushes a change and generates a repository
containing something like this:
* -- * -- B -- O -- O -- O (d24baacb05c)
\
N -- N -- N refs/heads/xiangfu0/agg-rewrite/04-any-value
(e952429935e)
You should already have received notification emails for all of the O
revisions, and so the following emails describe only the N revisions
from the common base, B.
Any revisions marked "omit" are not gone; other references still
refer to them. Any revisions marked "discard" are gone forever.
No new revisions were added by this update.
Summary of changes:
.github/workflows/build-all-pinot-docker-image.yml | 6 +-
.../workflows/build-pinot-base-docker-image.yml | 4 +-
.github/workflows/build-pinot-docker-image.yml | 2 +-
.github/workflows/build-superset-docker-image.yml | 2 +-
.../nightly-build-all-pinot-docker-image.yml | 6 +-
...htly-build-multi-arch-superset-docker-image.yml | 4 +-
.github/workflows/pr-flow-checks.yml | 2 +-
.github/workflows/pr-flow.yml | 4 +-
.mvn/extensions.xml | 2 +-
.../requesthandler/GrpcBrokerRequestHandler.java | 4 +-
.../MultiStageBrokerRequestHandler.java | 24 +-
.../SingleConnectionBrokerRequestHandler.java | 4 +-
.../MultiStageBrokerRequestHandlerTest.java | 111 +++++++-
.../apache/pinot/common/utils/ExceptionUtils.java | 45 ++++
.../pinot/common/utils/ExceptionUtilsTest.java | 129 +++++++++
.../exception/ControllerApplicationException.java | 23 +-
.../resources/PinotIngestionRestletResource.java | 27 +-
.../resources/WebApplicationExceptionMapper.java | 19 +-
...PinotIngestionRestletResourceStatelessTest.java | 86 +++++-
.../ControllerApplicationExceptionTest.java | 36 ++-
.../PinotIngestionRestletResourceTest.java | 140 ++++++++++
.../WebApplicationExceptionMapperTest.java | 98 +++++++
.../apache/pinot/core/common/ObjectSerDeUtils.java | 53 +++-
.../apache/pinot/core/data/table/TableResizer.java | 16 +-
.../function/ModeAggregationFunction.java | 201 +++++++++++++--
.../AggregateFunctionRewriteOptimizer.java | 28 ++
.../pinot/core/common/ObjectSerDeUtilsTest.java | 17 ++
.../function/ModeAggregationFunctionTest.java | 181 +++++++++++++
.../AggregateFunctionRewriteOptimizerTest.java | 25 ++
.../org/apache/pinot/queries/ModeQueriesTest.java | 210 ++++++++++++++-
.../tests/BaseClusterIntegrationTest.java | 20 +-
.../PinotAggregateTypeArgumentRewriteRule.java | 54 ++--
.../rel/rules/PinotJoinExchangeNodeInsertRule.java | 134 +++++++++-
.../org/apache/pinot/query/QueryEnvironment.java | 3 +-
.../rules/PinotJoinExchangeNodeInsertRuleTest.java | 143 ++++++++++
.../src/test/resources/queries/AggregatePlans.json | 26 ++
.../query/service/dispatch/QueryDispatcher.java | 57 +++-
.../service/dispatch/QueryDispatcherTest.java | 59 +++++
.../test/resources/queries/NonEquiOuterJoins.json | 58 +++++
.../src/test/resources/queries/QueryHints.json | 81 ++++++
.../src/test/resources/queries/UDFAggregates.json | 41 +++
.../MultiColumnRealtimeLuceneTextIndex.java | 2 +-
.../invertedindex/RealtimeLuceneTextIndex.java | 2 +-
.../segment/creator/RecordProcessingException.java | 16 +-
.../RecordReaderSegmentCreationDataSource.java | 2 +-
.../impl/SegmentIndexCreationDriverImpl.java | 3 +-
.../impl/inv/json/OffHeapJsonIndexCreator.java | 25 +-
.../creator/impl/text/LuceneTextIndexCreator.java | 112 ++++----
.../defaultcolumn/BaseDefaultColumnHandler.java | 57 ++--
.../index/readers/text/LuceneTextIndexReader.java | 164 +++---------
.../text/MultiColumnLuceneTextIndexReader.java | 4 +-
.../local/segment/store/TextIndexUtils.java | 68 +++++
.../creator/RecordProcessingExceptionTest.java | 143 ++++++++++
.../segment/local/segment/index/JsonIndexTest.java | 97 +++++++
.../index/creator/LuceneTextIndexCreatorTest.java | 287 +++++++++++++++++++--
.../local/segment/index/loader/LoaderTest.java | 54 ++--
.../index/loader/SegmentPreProcessorTest.java | 67 +++++
.../TextIndexRollbackRecoveryTest.java | 2 +-
.../text/LuceneTextIndexCompatibleTest.java | 174 ++++++++++++-
.../readers/text/LuceneTextIndexCountTest.java | 22 +-
.../segment/store/FilePerIndexDirectoryTest.java | 22 +-
.../store/SingleFileIndexDirectoryTest.java | 22 +-
.../pinot/segment/spi/AggregationFunctionType.java | 12 +-
.../pinot/segment/spi/index/TextIndexConfig.java | 6 +-
pom.xml | 16 +-
65 files changed, 3156 insertions(+), 408 deletions(-)
create mode 100644
pinot-common/src/test/java/org/apache/pinot/common/utils/ExceptionUtilsTest.java
create mode 100644
pinot-controller/src/test/java/org/apache/pinot/controller/api/resources/PinotIngestionRestletResourceTest.java
create mode 100644
pinot-controller/src/test/java/org/apache/pinot/controller/api/resources/WebApplicationExceptionMapperTest.java
create mode 100644
pinot-query-planner/src/test/java/org/apache/pinot/calcite/rel/rules/PinotJoinExchangeNodeInsertRuleTest.java
copy
pinot-clients/pinot-java-client/src/main/java/org/apache/pinot/client/admin/PinotAdminException.java
=>
pinot-segment-local/src/main/java/org/apache/pinot/segment/local/segment/creator/RecordProcessingException.java
(70%)
create mode 100644
pinot-segment-local/src/test/java/org/apache/pinot/segment/local/segment/creator/RecordProcessingExceptionTest.java
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]