This is an automated email from the ASF dual-hosted git repository.
jlli pushed a change to branch add-signiture-to-clean-up-tasks
in repository https://gitbox.apache.org/repos/asf/pinot.git
omit 03d68d729f Add nonLeaderCleanUp with tables parameters in
PinotTaskGenerator
add 2328d62606 Bump io.grpc:grpc-bom from 1.64.0 to 1.65.0 (#13507)
add a0e861e36f Support 'EXTRACT' as a scalar function (#13463)
add d447fcfa4f fix json_extract_index out of bounds case (#13479)
add 7062133323 Don't drop original field during flatten (#13490)
add 45b954e678 Add metric rules for newly added metrics (#13513)
add d5c4730ff7 add offloadSegmentUnafe to allow separate threads to manage
segment offloading (#13517)
add 225f699f5a Clean up TransformEvaluator (#13516)
add c156042c75 Fix NPE in Minion (#13518)
add f54559987e Handle unsupported exception gracefully (#13524)
add b8ccfadb43 Bump org.codehaus.mojo:versions-maven-plugin from 2.16.2 to
2.17.0 (#13512)
add 550f71bb14 Bump circe.version from 0.14.8 to 0.14.9 (#13519)
add 2e90f73bb4 Bump net.alchim31.maven:scala-maven-plugin from 4.9.1 to
4.9.2 (#13520)
add 0757b93d5c Bump software.amazon.awssdk:bom from 2.26.11 to 2.26.13
(#13522)
add 7213e137b8 Bump org.checkerframework:checker-qual from 3.44.0 to
3.45.0 (#13523)
add f4a1f56b6c Add table level metric for segment upload error (#13315)
add 897376e1ee Adapt group trim threshold to group trim size rather than
vice versa (#13514)
add af8dd9bfca make pom point to self (#13526)
add 55806ba484 Do not log exceptions when fetching offsets for lag metric
(#13528)
add fa5726d60c Bump org.apache.httpcomponents.core5:httpcore5 from 5.2.4
to 5.2.5 (#13530)
add 529fffbb88 Fixed nullPointerException in InputFileSegmentNameGenerator
when pattern contains optional part (#13532)
add cf1a0f6b9b Cleanup: Remove dependency on `nimbus-jose-jwt` in the
`pinot-adls` module. (#13534)
add 42b63d88b2 Fix issue with group by combine operator when limit is zero
(#13555)
add 4b5bd217e4 Return relevant error message when a v2 / multi-stage query
is run on the v1 query engine (#13554)
add 5e03263dfb Add hadoop-client-runtime dependency to fix quickstart
NoClassDefFoundError issue (#13548)
add 28f8455c73 Bump eclipse.jetty.version from 9.4.54.v20240208 to
9.4.55.v20240627 (#13542)
add 211ccead33 Bump net.openhft:posix from 2.26ea1 to 2.26ea2 (#13549)
add 2842df174c Bump com.fasterxml.jackson:jackson-bom from 2.12.7.20221012
to 2.17.2 (#13559)
add a76a590ba3 Bump software.amazon.awssdk:bom from 2.26.13 to 2.26.16
(#13558)
add c29efe703d Remove the usage of deprecated commons lang2
StringEscapeUtils (#13538)
add 2efd5cac01 return the current rebalance result if already done (#13488)
add f3e8666273 migrate from Apache HttpClient 4 to Apache HttpClient 5
(#13222)
add 48dfc0dcfb Add nonLeaderCleanUp with tables parameters in
PinotTaskGenerator
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 (03d68d729f)
\
N -- N -- N refs/heads/add-signiture-to-clean-up-tasks
(48dfc0dcfb)
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:
contrib/pinot-druid-benchmark/pom.xml | 6 +-
.../pinotdruidbenchmark/DruidResponseTime.java | 35 +-
.../pinotdruidbenchmark/DruidThroughput.java | 15 +-
.../pinotdruidbenchmark/PinotResponseTime.java | 35 +-
.../pinotdruidbenchmark/PinotThroughput.java | 12 +-
.../jmx_prometheus_javaagent/configs/minion.yml | 8 +-
.../jmx_prometheus_javaagent/configs/server.yml | 12 +-
.../broker/api/resources/PinotClientRequest.java | 2 +-
.../broker/broker/BrokerAdminApiApplication.java | 15 +-
.../BaseSingleStageBrokerRequestHandler.java | 24 +-
.../requesthandler/BrokerRequestHandler.java | 2 +-
.../BrokerRequestHandlerDelegate.java | 2 +-
.../MultiStageBrokerRequestHandler.java | 2 +-
.../org/apache/pinot/client/utils/DriverUtils.java | 4 +-
pinot-common/pom.xml | 12 +-
.../pinot/common/auth/AuthProviderUtils.java | 4 +-
.../pinot/common/function/DateTimeUtils.java | 40 +-
.../common/function/scalar/DateTimeFunctions.java | 5 +
.../apache/pinot/common/http/MultiHttpRequest.java | 37 +-
.../common/http/MultiHttpRequestResponse.java | 2 +-
.../pinot/common/metrics/ControllerMeter.java | 1 +
.../apache/pinot/common/minion/MinionClient.java | 84 +--
.../common/utils/FileUploadDownloadClient.java | 191 +++---
.../pinot/common/utils/RoundRobinURIProvider.java | 2 +-
.../org/apache/pinot/common/utils/SchemaUtils.java | 48 +-
.../org/apache/pinot/common/utils/URIUtils.java | 14 +-
.../common/utils/fetcher/HttpSegmentFetcher.java | 89 +--
.../apache/pinot/common/utils/http/HttpClient.java | 172 ++---
.../apache/pinot/common/utils/tls/TlsUtils.java | 2 +-
.../common/utils/webhdfs/WebHdfsV1Client.java | 55 +-
.../pinot/common/http/MultiHttpRequestTest.java | 6 +-
.../pinot/common/minion/MinionClientTest.java | 2 +-
.../protocols/SegmentCompletionProtocolTest.java | 4 +-
.../common/utils/FileUploadDownloadClientTest.java | 8 +-
.../pinot/sql/parsers/CalciteSqlCompilerTest.java | 37 +-
pinot-connectors/pinot-spark-common/pom.xml | 10 +-
.../pinot/connector/spark/common/HttpUtils.scala | 36 +-
.../pinot/controller/BaseControllerStarter.java | 14 +-
.../controller/api/resources/DebugResource.java | 2 +-
.../api/resources/PinotControllerLogger.java | 28 +-
.../api/resources/PinotQueryResource.java | 24 +-
.../api/resources/PinotRealtimeTableResource.java | 2 +-
.../api/resources/PinotRunningQueryResource.java | 82 +--
.../api/resources/PinotSegmentRestletResource.java | 2 +-
.../PinotSegmentUploadDownloadRestletResource.java | 3 +-
.../api/resources/PinotTableRestletResource.java | 38 +-
.../api/resources/PinotTaskRestletResource.java | 11 +-
.../api/resources/ServerTableSizeReader.java | 2 +-
.../pinot/controller/api/resources/TableSize.java | 2 +-
.../api/upload/SegmentValidationUtils.java | 2 +-
.../controller/helix/RealtimeConsumerMonitor.java | 2 +-
.../controller/helix/SegmentStatusChecker.java | 2 +-
.../helix/core/minion/ClusterInfoAccessor.java | 2 +-
.../core/minion/PinotHelixTaskResourceManager.java | 2 +-
.../helix/core/minion/PinotTaskManager.java | 2 +-
.../helix/core/relocation/SegmentRelocator.java | 2 +-
.../controller/util/CompletionServiceHelper.java | 8 +-
.../util/ConsumingSegmentInfoReader.java | 2 +-
.../util/ServerSegmentMetadataReader.java | 4 +-
.../controller/util/ServerTableTierReader.java | 2 +-
.../util/TableIngestionStatusHelper.java | 2 +-
.../pinot/controller/util/TableMetadataReader.java | 2 +-
.../pinot/controller/util/TableSizeReader.java | 2 +-
.../pinot/controller/util/TableTierReader.java | 2 +-
.../ConsumingSegmentInfoReaderStatelessTest.java | 4 +-
.../pinot/controller/api/PinotFileUploadTest.java | 27 +-
...PinotIngestionRestletResourceStatelessTest.java | 16 +-
.../controller/api/PinotSegmentsMetadataTest.java | 4 +-
.../controller/api/ServerTableSizeReaderTest.java | 2 +-
.../pinot/controller/api/TableSizeReaderTest.java | 4 +-
.../pinot/controller/api/TableTierReaderTest.java | 4 +-
.../api/resources/PinotQueryResourceTest.java | 76 +++
.../pinot/controller/helix/ControllerTest.java | 2 +-
.../core/relocation/SegmentRelocatorTest.java | 2 +-
.../apache/pinot/core/common/DataBlockCache.java | 122 ----
.../org/apache/pinot/core/common/DataFetcher.java | 227 +------
.../evaluators/DefaultJsonPathEvaluator.java | 704 ---------------------
.../core/data/manager/BaseTableDataManager.java | 16 +
.../manager/realtime/IngestionDelayTracker.java | 4 +
.../realtime/RealtimeSegmentDataManager.java | 30 +-
.../apache/pinot/core/data/table/IndexedTable.java | 25 +-
.../core/operator/blocks/ProjectionBlock.java | 123 ----
.../function/ExtractTransformFunction.java | 66 +-
.../function/IdentifierTransformFunction.java | 65 +-
.../JsonExtractIndexTransformFunction.java | 2 +-
.../JsonExtractScalarTransformFunction.java | 264 +++-----
.../function/PushDownTransformFunction.java | 135 ----
.../evaluators/DefaultJsonPathEvaluatorTest.java | 146 -----
.../pinot/core/data/table/IndexedTableTest.java | 58 +-
.../function/ExtractTransformFunctionTest.java | 3 +
.../queries/JsonIngestionFromAvroQueriesTest.java | 84 ++-
.../JsonUnnestIngestionFromAvroQueriesTest.java | 394 ++++++++++++
.../pinot/integration/tests/ClusterTest.java | 10 +-
...ssageDecoderRealtimeClusterIntegrationTest.java | 2 +-
.../tests/LLCRealtimeClusterIntegrationTest.java | 2 +-
.../tests/OfflineClusterIntegrationTest.java | 17 +-
.../integration/tests/TlsIntegrationTest.java | 39 +-
.../plugin/provider/AzureEnvironmentProvider.java | 64 +-
.../provider/AzureEnvironmentProviderTest.java | 50 +-
pinot-plugins/pinot-file-system/pinot-adls/pom.xml | 4 -
.../pinot-input-format/pinot-parquet/pom.xml | 5 +
.../BaseMultipleSegmentsConversionExecutor.java | 8 +-
.../tasks/BaseSingleSegmentConversionExecutor.java | 10 +-
.../minion/tasks/SegmentConversionUtils.java | 10 +-
.../minion/tasks/SegmentConversionUtilsTest.java | 2 +-
.../rel/rules/PinotEvaluateLiteralRule.java | 3 +
.../pinot/query/parser/utils/ParserUtils.java | 54 ++
.../query/runtime/queries/QueryRunnerTest.java | 2 +-
.../local/data/manager/TableDataManager.java | 7 +
.../recordtransformer/ComplexTypeTransformer.java | 24 +-
.../recordtransformer/ExpressionTransformer.java | 35 +-
.../upsert/BasePartitionUpsertMetadataManager.java | 4 +-
.../segment/local/utils/SegmentPushUtils.java | 6 +-
.../ComplexTypeTransformerTest.java | 14 +-
.../name/InputFileSegmentNameGenerator.java | 6 +-
.../segment/spi/evaluator/TransformEvaluator.java | 168 -----
.../spi/evaluator/json/JsonPathEvaluator.java | 30 -
.../evaluator/json/JsonPathEvaluatorProvider.java | 33 -
.../spi/evaluator/json/JsonPathEvaluators.java | 147 -----
.../spi/index/metadata/ColumnMetadataImpl.java | 2 +-
.../name/InputFileSegmentNameGeneratorTest.java | 28 +-
.../apache/pinot/spi/data/readers/GenericRow.java | 14 +
.../org/apache/pinot/tools/BootstrapTableTool.java | 2 +-
.../admin/command/AbstractBaseAdminCommand.java | 2 +-
.../tools/admin/command/ChangeTableState.java | 23 +-
.../admin/command/OperateClusterConfigCommand.java | 2 +-
.../tools/admin/command/UploadSegmentCommand.java | 2 +-
.../streams/githubevents/GitHubAPICaller.java | 70 +-
pom.xml | 42 +-
129 files changed, 1866 insertions(+), 2969 deletions(-)
create mode 100644
pinot-controller/src/test/java/org/apache/pinot/controller/api/resources/PinotQueryResourceTest.java
delete mode 100644
pinot-core/src/main/java/org/apache/pinot/core/common/evaluators/DefaultJsonPathEvaluator.java
delete mode 100644
pinot-core/src/main/java/org/apache/pinot/core/operator/transform/function/PushDownTransformFunction.java
delete mode 100644
pinot-core/src/test/java/org/apache/pinot/core/common/evaluators/DefaultJsonPathEvaluatorTest.java
create mode 100644
pinot-core/src/test/java/org/apache/pinot/queries/JsonUnnestIngestionFromAvroQueriesTest.java
create mode 100644
pinot-query-planner/src/main/java/org/apache/pinot/query/parser/utils/ParserUtils.java
delete mode 100644
pinot-segment-spi/src/main/java/org/apache/pinot/segment/spi/evaluator/TransformEvaluator.java
delete mode 100644
pinot-segment-spi/src/main/java/org/apache/pinot/segment/spi/evaluator/json/JsonPathEvaluator.java
delete mode 100644
pinot-segment-spi/src/main/java/org/apache/pinot/segment/spi/evaluator/json/JsonPathEvaluatorProvider.java
delete mode 100644
pinot-segment-spi/src/main/java/org/apache/pinot/segment/spi/evaluator/json/JsonPathEvaluators.java
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@pinot.apache.org
For additional commands, e-mail: commits-h...@pinot.apache.org
