This is an automated email from the ASF dual-hosted git repository.
github-bot pushed a change to branch
dependabot/maven/org.mockito-mockito-bom-5.21.0
in repository https://gitbox.apache.org/repos/asf/pinot.git
discard 5c926510a35 Bump org.mockito:mockito-bom from 5.17.0 to 5.21.0
add 52d0f8c3bbf Update time zone spec for more timezone support (#17543)
add b8bf104d0e6 Enhance ThreadResourceUsageProvider setup and
getCurrentThreadAllocatedBytes() (#17541)
add ae27b630fac Fix typo in UserConfig method name - getPermissios to
getPermissions (#17522)
add ea2601e4e1a Upgrade HTTP core5 and client5 version (#17547)
add 0b6606a17e4 Bump lodash in /pinot-controller/src/main/resources
(#17548)
add 59dd2125eff Set SSL context in
ControllerContext/BrokerContext/ServerContext and use it (#17358)
add 16faac8caf5 Fix double-unescaping of SQL string literals in
single-stage engine (#17438)
add 7f69de9d5d4 Bump software.amazon.awssdk:bom from 2.41.11 to 2.41.12
(#17554)
add 9f12cd29759 Bump org.testng:testng from 7.11.0 to 7.12.0 (#17555)
add d54ec21ad56 Add check to not enable dropOutOfOrderRecord or
outOfOrderColumn when consistencyMode != NONE (#17550)
add 4c7fd6f333f Continue Freshness check if latest stream offset fetch
fails (#17563)
add aa8b9a14205 Bump software.amazon.awssdk:bom from 2.41.12 to 2.41.13
(#17561)
add b3b72ae514e [bugfix] Handling runtime exceptions for
RemoteClusterBrokerRoutingManager routing methods (#17564)
add 008ad90a530 Skip Freshness check for streams not supporting offset lag
(#17560)
add 19d0bf62417 Deterministically order dimension-table segments during
lookup loading (#17536)
add c611859a289 Bump net.alchim31.maven:scala-maven-plugin from 4.9.8 to
4.9.9 (#17574)
add 5d1359aadf7 Bump org.objenesis:objenesis from 3.4 to 3.5 (#17573)
add 41ff403b55c Bump org.glassfish.tyrus.bundles:tyrus-standalone-client
(#17572)
add 6f015cb1c6c Bump org.assertj:assertj-bom from 3.27.6 to 3.27.7 (#17571)
add 713a389bf11 Bump software.amazon.awssdk:bom from 2.41.13 to 2.41.14
(#17570)
add 24c663f636a Bump com.gradle:develocity-maven-extension from 2.3.1 to
2.3.2 (#17568)
add 234d3823964 Bump io.dropwizard.metrics:metrics-bom from 4.2.37 to
4.2.38 (#17569)
add 30fca7c0385 Enable broker gRPC only for quickstarts. (#17575)
add 78613ef3150 [spi] Fix Schema/TableConfigs serialization with JsonValue
annotation (#17558)
add ef52ee84337 include primary key in the pinot schema ui (#17566)
add f71a60d9d42 Bump software.amazon.awssdk:bom from 2.41.14 to 2.41.15
(#17583)
add bfc21bf6806 Reduce array copying for non-equi join condition
evaluation for LookupJoinOperator (#17542)
add fc81e8e4e5f Support MinionContext AuthProvider in Minion executors
(#17405)
add d4dec25b886 Add runtime TLS diagnostics for gRPC and HTTPS (#17559)
add 44269a8de9e [bugfix] Propagate error messages correctly in timeseries
engine (#17577)
add b4081d60033 Bump software.amazon.awssdk:bom from 2.41.15 to 2.41.16
(#17589)
add dcbb620b9e6 Print throttled warn log for issues during continueOnError
(#17592)
add 9ef03d0474d Optimize ProtoBufRecordExtractor with field descriptor
caching (#17593)
add 8569e6ba785 Bump software.amazon.awssdk:bom from 2.41.16 to 2.41.17
(#17595)
add 3a7665e4393 Fix multi-stage query stats serde compatibility issue
caused by UNNEST (#17590)
add 5db1c329bcd Bump com.gradle:develocity-maven-extension from 2.3.2 to
2.3.3 (#17596)
add 0a951fa7969 Add Storage Quota Check to Batch Segments Upload (#17512)
add 5d898ca18b3 Bump software.amazon.awssdk:bom from 2.41.17 to 2.41.18
(#17603)
add 77a3dd6cf14 Bump commons-codec:commons-codec from 1.20.0 to 1.21.0
(#17604)
add b248ae3f15e Add @Authenticate annotation to critical endpoints (#17552)
add 128003a8f4a handle cases where CTE has the same name as table (#17591)
add 36ac509f8f6 feat(helm): add pdb for minion and minion-stateless
(#17538)
add 32f0a2dc240 Bump com.azure:azure-sdk-bom from 1.3.3 to 1.3.4 (#17608)
add 736ea3b9b64 Bump software.amazon.awssdk:bom from 2.41.18 to 2.41.19
(#17609)
add 8de3f2fb652 Bump com.github.seancfoley:ipaddress from 5.5.1 to 5.6.1
(#17612)
add 01dc40c613b Bump Confluent library to 7.9.5 to match Kafka version
3.9.1 (#17614)
add e4f27fdf489 Add more AI tooling working/tmp dir to .gitignore (#17617)
add 7305eec8581 Add genai related files to ignore for apache-rat-plugin
(#17616)
add 748310409c6 Bump org.checkerframework:checker-qual from 3.53.0 to
3.53.1 (#17620)
add 564a2a34998 Bump software.amazon.awssdk:bom from 2.41.19 to 2.41.20
(#17621)
add 441d335dcf0 Isolate potentially long-running minion task API resources
on controller (#17494)
add 30b5490db15 [spi] Fix Asymmetric Serialization in TextIndexConfig
(#17628)
add 1a55cea2821 Bump software.amazon.awssdk:bom from 2.41.20 to 2.41.21
(#17629)
add 6083e548eab Bump io.grpc:grpc-bom from 1.78.0 to 1.79.0 (#17630)
add 37fe83751c8 Fix bug with 'useLeafServerForIntermediateStage' when used
with empty tables (#17634)
add d6ca0c78b86 Consolidate MV aggregations into regular SV aggregations
(#17519)
add ca952da64b1 Pull resolveAuthProvider into MinionTaskUtils for reuse in
other utils (#17626)
add 783075165da Add configs when initing column reader factory (#17635)
add 82b7d187ecb Add ideal state replica ID information for query routing
(#17619)
add e5f5994fdd0 Wrong pinot.minion.tls.keystore.type in TLS Integration
Test (#17641)
add 37845059c35 Bump com.github.luben:zstd-jni from 1.5.7-6 to 1.5.7-7
(#17636)
add 4a2f8c720f7 Bump org.jetbrains.kotlin:kotlin-bom from 2.3.0 to 2.3.10
(#17637)
add a6ed13019e5 Bump com.google.errorprone:error_prone_annotations from
2.46.0 to 2.47.0 (#17638)
add afff932c854 Bump software.amazon.awssdk:bom from 2.41.21 to 2.41.22
(#17639)
add 3f5466035ac Fix ResponseStoreCleaner bugs causing unbounded response
store growth and cleanup failures (#17622)
add a5eae57fc81 Add Kafka 4.x client support (#17633)
add b8645efa62f Bump software.amazon.awssdk:bom from 2.41.22 to 2.41.23
(#17654)
add aa47bff3fb4 Bump webpack in /pinot-controller/src/main/resources
(#17648)
add 4ef8e3eafd1 [spi] Fix input format resolution inconsistency between
PluginManager and RecordReaderFactory (#17601)
add 3a536f30403 remove compatibility verifier for 1.3.0 (#17649)
add cd48d5e8c0b Support TLS routing for logical tables (#17663)
add cdfd474544c Bump software.amazon.awssdk:bom from 2.41.23 to 2.41.24
(#17666)
add b946b73ce1f Bump com.microsoft.azure:msal4j from 1.23.1 to 1.24.0
(#17665)
add f801a35d7ba Bump org.eclipse.sisu:sisu-maven-plugin from 0.9.0.M4 to
1.0.0 (#17664)
add 722d1e42873 Change the default settings to DISALLOW_ALWAYS for a
dropOutOfOrderRecord tables as well (#17671)
add 08edbc98106 freshness checkers uses minimum ingestion lag (#17598)
add 0f93d52ef0b [audit] Add SPI-based token resolver for custom audit
identity resolution (#17658)
add b03be818f9f Bump software.amazon.awssdk:bom from 2.41.24 to 2.41.25
(#17673)
add 5be01efb693 [federation] Added MULTI_CLUSTER QuickStart for
multi-cluster routing (#17581)
add 60620225a4a Bump org.apache.httpcomponents.core5:httpcore5 from 5.4 to
5.4.1 (#17680)
add 4d5c6806ec7 Bump com.gradle:develocity-maven-extension from 2.3.3 to
2.3.4 (#17681)
add 870bb0c6f99 Bump software.amazon.awssdk:bom from 2.41.25 to 2.41.26
(#17682)
add 19c9c2d7163 Add access control to segment download API (#17508)
add 05fb118520d Fix DirectOOMHandler string matching bug that missed Netty
direct memory OOM (#17684)
add cb8eabca329 [core] Fix truncate(value) signed-zero and non-finite
behavior (#17677)
add 88f523afb22 Refactor table config validations for create and update
table to TableConfigValidationUtils (#17679)
add 856095392e4 Add logical table support to TLS integration tests (#17683)
add b8eafc1bf54 Add pluggable table samplers with precomputed broker
routing entries and tableSampler query option (#17532)
add f15c471a514 Keep stats during pipeline breaker (#17576)
add 5b4c0b991ae Bump org.asynchttpclient:async-http-client from 3.0.6 to
3.0.7 (#17689)
add 6f0a22d8772 Bump software.amazon.awssdk:bom from 2.41.26 to 2.41.27
(#17690)
add b4e48d561fc Remove MSE compatibility verifier for 1.3.0 (#17693)
add 76cd3e69a4b Fix funnel aggregation worker threads not responding to
query timeout / cancellation (#17692)
add eb4e45e3665 Bump testcontainers to 1.21.4 to fix Docker issue (#17704)
add b0cb6cc97c0 Bump software.amazon.awssdk:bom from 2.41.27 to 2.41.28
(#17698)
add 657e7f075f7 Support metadata push mode in
BaseSingleSegmentConversionExecutor (#17632)
add 8a3c1ca3081 Add termination checks to FunnelEventsFunctionEval and
FunnelStepDurationStats (#17700)
add 60b1f56a839 Bump software.amazon.awssdk:bom from 2.41.29 to 2.41.30
(#17715)
add f197b790398 Improve GcsPinotFS deleteBatch resiliency (#17713)
add a1f2f6a8ab3 [timeseries] Adding timeUsedMs to query statistics (#17676)
add 9d70f87c57e do not log actual data on segment creation (#17656)
add 7469366011e Fix S3PinotFs URL Encoding for S3 Compatible storage
(#17691)
add 2c4e83e41bc Upgrade testcontainers to 2.x (#17705)
add 4c14b4589b0 Add metrics for serialized query response size in
QueryScheduler (#17710)
add 1664ef957bf Bump software.amazon.awssdk:bom from 2.41.30 to 2.41.31
(#17721)
add 7d103b6cc1a Better netty inspection (#17674)
add 525a8d0d227 Rename DictionaryIndexConfig.getUseVarLengthDictionary to
isUseVarLengthDictionary (#17662)
add 402e88ada4c Revert "Add validation for tiered storage in Upsert/Dedup
tables. (#17064)" (#17726)
add 5c682b893ff Bump org.jetbrains:annotations from 26.0.2-1 to 26.1.0
(#17728)
add 5f50d353dae Bump software.amazon.awssdk:bom from 2.41.31 to 2.41.32
(#17727)
add 570d4f11a9b Add authz action checks to missing APIs (#17725)
add eb6b0718c94 Fix NPE in TableRebalancer (#17723)
add 33bb182c4d9 [controller] Avoid eager IdealState fetch in LLC segment
commit (#17707)
add 380477a6160 Remove kafka-2.0 plugin and migrate to kafka30 (#17602)
add 063b6e4e9ef Handle mixed-type map key values by promoting to string
(#17722)
add 6d0eb45c9c8 Add INITCAP scalar function to Apache Pinot (#17642)
add 9de73ec47cb Refactor exception handling to use ExceptionUtils for
better suppression of multiple exceptions (#17724)
add 8ae1048bdb6 bugfix: CustomDataQueryClusterIntegrationTest shouldn't
create kafka topic during the setupSuite call and use kafka binary for
compatibility tests (#17738)
add 4a99cd8a81d Bump com.nimbusds:nimbus-jose-jwt from 10.7 to 10.8
(#17732)
add 8fb9b619da4 Bump org.roaringbitmap:RoaringBitmap from 1.3.0 to 1.6.10
(#17735)
add 490e07cd1c0 Bump com.fasterxml.jackson:jackson-bom from 2.21.0 to
2.21.1 (#17743)
add 8284e000b42 Bump software.amazon.awssdk:bom from 2.41.32 to 2.41.34
(#17744)
add 9f4a7d6f8be Bump com.mchange:mchange-commons-java from 0.3.2 to 0.4.0
(#17742)
add 02214a34322 Bump org.webjars:swagger-ui from 5.31.0 to 5.31.2 (#17745)
add 739043c09b4 Bump kafka3.version from 3.9.1 to 3.9.2 (#17747)
add f90d1045e69 Bump org.mockito:mockito-bom from 5.17.0 to 5.21.0
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 (5c926510a35)
\
N -- N -- N
refs/heads/dependabot/maven/org.mockito-mockito-bom-5.21.0 (f90d1045e69)
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/pinot_tests.yml | 4 +-
.gitignore | 45 +-
.mvn/extensions.xml | 2 +-
AGENTS.md | 1 -
compatibility-verifier/compCheck.sh | 70 +-
.../config/feature-test-2-realtime.json | 2 +-
.../config/feature-test-2-realtime.json | 2 +-
.../config/feature-test-3-realtime.json | 2 +-
docker/images/pinot/README.md | 2 +-
.../airlineStats_realtime_table_config.json | 2 +-
.../meetupRsvp_realtime_table_config.json | 2 +-
helm/pinot/pinot-github-events-setup.yml | 2 +-
helm/pinot/pinot-realtime-quickstart.yml | 4 +-
.../poddisruptionbudget.yaml | 24 +-
.../poddisruptionbudget.yaml | 24 +-
helm/pinot/values.yaml | 17 +-
.../broker/broker/helix/BaseBrokerStarter.java | 25 +-
.../apache/pinot/broker/grpc/BrokerGrpcServer.java | 10 +-
.../requesthandler/TimeSeriesRequestHandler.java | 17 +-
.../instanceselector/BaseInstanceSelector.java | 37 +-
.../ReplicaGroupInstanceSelector.java | 18 +-
.../instanceselector/SegmentInstanceCandidate.java | 12 +-
.../routing/manager/BaseBrokerRoutingManager.java | 166 ++++-
.../manager/MultiClusterRoutingManager.java | 9 +-
.../manager/RemoteClusterBrokerRoutingManager.java | 25 +-
.../tablesampler/FirstNSegmentsTableSampler.java | 76 +++
.../broker/routing/tablesampler/TableSampler.java | 48 ++
.../routing/tablesampler/TableSamplerFactory.java | 164 +++++
.../routing/manager/BrokerRoutingManagerTest.java | 58 ++
.../manager/MultiClusterRoutingManagerTest.java | 33 +-
.../tablesampler/TableSamplerFactoryTest.java | 98 +++
.../external/ExternalAnnotatedSampler.java} | 21 +-
.../org/apache/pinot/client/AbstractResultSet.java | 3 +
.../java/org/apache/pinot/client/BrokerCache.java | 2 +
.../org/apache/pinot/client/BrokerResponse.java | 6 +
.../pinot/client/CursorAwareBrokerResponse.java | 14 +
.../pinot/client/DefaultSslContextProvider.java | 62 ++
.../client/JsonAsyncHttpPinotClientTransport.java | 16 +-
.../java/org/apache/pinot/client/ResultSet.java | 3 +
.../apache/pinot/client/SslContextProvider.java | 28 +-
.../pinot/client/SslContextProviderFactory.java | 121 ++++
.../pinot/client/SslContextProviderTest.java | 301 +++++++++
.../org/apache/pinot/common/audit/AuditConfig.java | 12 +
.../org/apache/pinot/common/audit/AuditEvent.java | 3 +-
.../pinot/common/audit/AuditIdentityResolver.java | 105 ++-
.../pinot/common/function/DateTimeUtils.java | 8 -
.../apache/pinot/common/function/TimeZoneKey.java | 40 +-
.../common/function/scalar/StringFunctions.java | 34 +
.../pinot/common/metrics/ControllerGauge.java | 4 +-
.../apache/pinot/common/metrics/ServerMeter.java | 7 +
.../response/mapper/TimeSeriesResponseMapper.java | 11 +
.../common/utils/ClientSSLContextGenerator.java | 62 +-
.../apache/pinot/common/utils/ExceptionUtils.java | 109 ++++
.../org/apache/pinot/common/utils/FileUtils.java | 6 +-
.../common/utils/LogicalTableConfigUtils.java | 22 +
.../pinot/common/utils/ServiceStartableUtils.java | 9 +
.../utils/config/AccessControlUserConfigUtils.java | 4 +-
.../common/utils/config/QueryOptionsUtils.java | 9 +-
.../common/utils/config/TableConfigSerDeUtils.java | 14 +-
.../common/utils/grpc/BaseGrpcQueryClient.java | 4 +
.../pinot/common/utils/request/RequestUtils.java | 11 +-
.../apache/pinot/common/utils/tls/TlsUtils.java | 97 +++
.../sql/parsers/parser/TableNameExtractor.java | 11 +-
.../src/main/resources/zone-index.properties | 28 +-
.../common/audit/AuditIdentityResolverTest.java | 145 ++---
.../pinot/common/audit/MockAuditTokenResolver.java | 93 +++
.../function/scalar/StringFunctionsTest.java | 58 ++
.../common/utils/config/QueryOptionsUtilsTest.java | 15 +
.../pinot/sql/parsers/CalciteSqlParserTest.java | 175 +++++
.../sql/parsers/parser/TableNameExtractorTest.java | 15 +
.../java/org/apache/pinot/compat/StreamOp.java | 2 +-
.../spark/v3/datasource/PinotDataWriter.scala | 2 +-
pinot-controller/pom.xml | 1 +
.../pinot/controller/BaseControllerStarter.java | 30 +
.../api/ControllerAdminApiApplication.java | 46 +-
.../pinot/controller/api/resources/Constants.java | 2 +
.../PinotAccessControlUserRestletResource.java | 1 +
.../PinotApplicationQuotaRestletResource.java | 3 +
...PinotControllerPeriodicTaskRestletResource.java | 3 +
.../resources/PinotDatabaseRestletResource.java | 4 +
.../api/resources/PinotLogicalTableResource.java | 27 +-
.../api/resources/PinotRealtimeTableResource.java | 7 +
.../api/resources/PinotRunningQueryResource.java | 5 +
.../PinotSegmentUploadDownloadRestletResource.java | 87 ++-
.../api/resources/PinotTableRestletResource.java | 58 +-
.../api/resources/PinotTaskRestletResource.java | 471 ++++++++++----
.../api/resources/PinotTenantRestletResource.java | 1 +
.../api/resources/PinotUpsertRestletResource.java | 3 +
.../api/resources/TableConfigValidationUtils.java | 94 +++
.../controller/cursors/ResponseStoreCleaner.java | 164 +++--
.../controller/helix/ControllerRequestClient.java | 24 +
.../realtime/PinotLLCRealtimeSegmentManager.java | 155 +++--
.../core/rebalance/DefaultRebalancePreChecker.java | 2 +-
.../helix/core/rebalance/RebalancePreChecker.java | 2 +-
.../helix/core/rebalance/TableRebalancer.java | 28 +-
.../Homepage/Operations/AddIngestionComponent.tsx | 2 +-
.../Operations/AddRealTimeIngestionComponent.tsx | 2 +-
.../Homepage/Operations/AddRealtimeTableOp.tsx | 2 +-
.../components/Query/FlamegraphQueryStageStats.tsx | 78 ++-
.../src/main/resources/app/pages/TenantDetails.tsx | 2 +-
.../src/main/resources/app/utils/Utils.tsx | 5 +-
.../src/main/resources/package-lock.json | 305 +++++----
pinot-controller/src/main/resources/package.json | 4 +-
.../resources/PinotTaskRestletResourceTest.java | 54 +-
.../cursors/ResponseStoreCleanerTest.java | 333 ++++++++++
.../PinotLLCRealtimeSegmentManagerTest.java | 158 ++++-
.../pinot/core/auth/BasicAuthPrincipalUtils.java | 2 +-
.../core/data/manager/BaseTableDataManager.java | 3 +-
.../manager/offline/DimensionTableDataManager.java | 23 +-
.../realtime/RealtimeSegmentDataManager.java | 9 +-
.../pinot/core/instance/context/BrokerContext.java | 98 +++
.../core/instance/context/ControllerContext.java | 84 +++
.../pinot/core/instance/context/ServerContext.java | 98 +++
.../function/TruncateDecimalTransformFunction.java | 17 +-
.../DistinctCountBitmapAggregationFunction.java | 223 +++++++
.../DistinctCountBitmapMVAggregationFunction.java | 198 +-----
.../DistinctCountHLLAggregationFunction.java | 233 +++++++
.../DistinctCountHLLMVAggregationFunction.java | 212 +------
.../DistinctCountHLLPlusAggregationFunction.java | 236 +++++++
.../DistinctCountHLLPlusMVAggregationFunction.java | 212 +------
.../function/PercentileAggregationFunction.java | 69 +-
.../function/PercentileEstAggregationFunction.java | 126 +++-
.../PercentileEstMVAggregationFunction.java | 28 +-
.../function/PercentileKLLAggregationFunction.java | 112 +++-
.../PercentileKLLMVAggregationFunction.java | 64 +-
.../function/PercentileMVAggregationFunction.java | 28 +-
.../PercentileTDigestAggregationFunction.java | 128 +++-
.../PercentileTDigestMVAggregationFunction.java | 28 +-
.../window/FunnelBaseAggregationFunction.java | 5 +
.../FunnelCompleteCountAggregationFunction.java | 4 +
...unnelEventsFunctionEvalAggregationFunction.java | 9 +
.../window/FunnelMatchStepAggregationFunction.java | 4 +
.../window/FunnelMaxStepAggregationFunction.java | 4 +
...FunnelStepDurationStatsAggregationFunction.java | 4 +
.../pinot/core/query/scheduler/QueryScheduler.java | 32 +-
.../pinot/core/routing/LogicalTableRouteInfo.java | 6 +-
.../apache/pinot/core/routing/RoutingManager.java | 9 +
.../segment/processing/mapper/SegmentMapper.java | 5 +-
.../pinot/core/transport/DataTableHandler.java | 7 +
.../pinot/core/transport/DirectOOMHandler.java | 15 +-
.../pinot/core/transport/NettyInspector.java | 140 ++++
.../apache/pinot/core/transport/NettyInstance.java | 133 ++++
.../pinot/core/transport/grpc/GrpcQueryServer.java | 4 +
.../pinot/core/accounting/TestThreadMXBean.java | 34 +
.../TruncateDecimalTransformFunctionTest.java | 35 +
...tinctCountBitmapMVAggregationFunctionTest.java} | 74 +--
...DistinctCountHLLMVAggregationFunctionTest.java} | 74 +--
...inctCountHLLPlusMVAggregationFunctionTest.java} | 74 +--
...=> PercentileEstMVAggregationFunctionTest.java} | 78 +--
...=> PercentileKLLMVAggregationFunctionTest.java} | 78 +--
...va => PercentileMVAggregationFunctionTest.java} | 74 +--
...ercentileTDigestMVAggregationFunctionTest.java} | 78 +--
...ogicalTableRouteProviderCalculateRouteTest.java | 71 +++
...> DistinctCountBitmapWithMVStarTreeV2Test.java} | 7 +-
...a => DistinctCountHLLWithMVStarTreeV2Test.java} | 7 +-
...java => PercentileEstWithMVStarTreeV2Test.java} | 7 +-
... => PercentileTDigestWithMVStarTreeV2Test.java} | 17 +-
.../pinot/core/transport/DirectOOMHandlerTest.java | 64 ++
pinot-distribution/pinot-assembly.xml | 16 +-
.../tests/BaseClusterIntegrationTest.java | 453 ++++++++++++-
.../tests/ClusterIntegrationTestUtils.java | 41 +-
pinot-integration-tests/pom.xml | 7 +-
.../tests/BaseRealtimeClusterIntegrationTest.java | 12 +-
.../tests/CommitTimeCompactionIntegrationTest.java | 1 +
...tlyOnceKafkaRealtimeClusterIntegrationTest.java | 87 ++-
.../tests/LLCRealtimeClusterIntegrationTest.java | 4 +-
...> LLCRealtimeKafka4ClusterIntegrationTest.java} | 22 +-
.../MergeRollupMinionClusterIntegrationTest.java | 4 +-
.../MultiStageEngineExplainIntegrationTest.java | 2 +-
.../tests/MultiStageEngineIntegrationTest.java | 119 +++-
.../tests/OfflineClusterIntegrationTest.java | 44 ++
...geMetadataPushMinionClusterIntegrationTest.java | 76 +++
.../tests/PurgeMinionClusterIntegrationTest.java | 2 +-
.../tests/QueryQuotaClusterIntegrationTest.java | 3 +-
.../tests/QueryThreadContextIntegrationTest.java | 2 +-
...ntMetadataPushMinionClusterIntegrationTest.java | 71 +++
...RefreshSegmentMinionClusterIntegrationTest.java | 2 +-
.../tests/SimpleMinionClusterIntegrationTest.java | 2 +-
.../integration/tests/SpoolIntegrationTest.java | 2 +-
.../tests/TimeSeriesIntegrationTest.java | 1 +
.../integration/tests/TlsIntegrationTest.java | 59 +-
.../CustomDataQueryClusterIntegrationTest.java | 158 +++--
...ieldTypeMixedValueIngestingIntegrationTest.java | 144 +++++
.../tests/custom/TableSamplerIntegrationTest.java | 175 +++++
.../schemaregistry/SchemaRegistryStarter.java | 3 +-
...aIncreaseDecreasePartitionsIntegrationTest.java | 7 +-
.../pinot/integration/tests/udf/UdfTest.java | 2 +-
.../simpleMeetup_realtime_table_config.json | 2 +-
.../api/resources/PinotMinionAppConfigs.java | 4 +
.../minion/api/resources/PinotMinionLogger.java | 8 +
.../api/resources/PinotMinionMetricsResource.java | 4 +
.../api/resources/PinotTaskProgressResource.java | 6 +
.../minion/taskfactory/TaskFactoryRegistry.java | 9 -
pinot-perf/pom.xml | 10 +-
.../perf/BenchmarkProtoBufRecordExtractor.java | 323 ++++++++++
.../perf/BenchmarkThreadResourceUsageProvider.java | 56 +-
.../src/main}/resources/complex_types.desc | Bin
.../apache/pinot/plugin/filesystem/GcsPinotFS.java | 7 +-
pinot-plugins/pinot-file-system/pinot-s3/pom.xml | 5 +-
.../apache/pinot/plugin/filesystem/S3PinotFS.java | 15 +-
.../pinot/plugin/filesystem/S3PinotFSCopyTest.java | 396 ++++++++++++
.../pinot/plugin/filesystem/S3PinotFSTest.java | 15 +-
.../pinot-confluent-json/pom.xml | 2 +-
.../schemaregistry/SchemaRegistryStarter.java | 3 +-
.../pinot-confluent-protobuf/pom.xml | 2 +-
.../schemaregistry/SchemaRegistryStarter.java | 3 +-
.../pinot-input-format/pinot-protobuf/pom.xml | 15 -
.../inputformat/protobuf/ProtoBufFieldInfo.java | 16 +
.../protobuf/ProtoBufRecordExtractor.java | 93 ++-
.../ProtoBufRecordExtractorCachingTest.java | 367 +++++++++++
.../BaseMultipleSegmentsConversionExecutor.java | 121 +---
.../tasks/BaseSingleSegmentConversionExecutor.java | 75 ++-
.../plugin/minion/tasks/BaseTaskExecutor.java | 138 ++++
.../pinot/plugin/minion/tasks/MinionTaskUtils.java | 67 +-
.../minion/tasks/purge/PurgeTaskGenerator.java | 2 +
.../RefreshSegmentTaskGenerator.java | 1 +
.../SegmentGenerationAndPushTaskExecutor.java | 19 +-
.../UpsertCompactionTaskGenerator.java | 1 +
...BaseMultipleSegmentsConversionExecutorTest.java | 126 ++++
.../plugin/minion/tasks/MinionTaskUtilsTest.java | 15 +
pinot-plugins/pinot-stream-ingestion/README.md | 2 +-
.../pinot-kafka-2.0/README.md | 42 --
.../kafka20/server/KafkaDataServerStartable.java | 171 -----
...tionLevelConsumerBackwardCompatibilityTest.java | 30 -
.../stream/kafka20/utils/MiniKafkaCluster.java | 125 ----
.../kafka30/KafkaStreamMetadataProvider.java | 84 ++-
.../stream/kafka30}/server/KafkaDataProducer.java | 9 +-
.../kafka30/server/KafkaServerStartable.java | 701 +++++++++++++++++++++
...g.apache.pinot.spi.stream.StreamConsumerFactory | 2 +-
.../kafka30/KafkaPartitionLevelConsumerTest.java | 26 +-
.../kafka30/server/KafkaServerStartableTest.java | 102 +++
.../stream/kafka30/utils/MiniKafkaCluster.java | 138 ----
.../{pinot-kafka-2.0 => pinot-kafka-4.0}/pom.xml | 27 +-
.../stream/kafka40}/KafkaConsumerFactory.java | 2 +-
.../KafkaPartitionLevelConnectionHandler.java | 4 +-
.../kafka40}/KafkaPartitionLevelConsumer.java | 2 +-
.../kafka40}/KafkaStreamMetadataProvider.java | 120 +++-
.../SynchronizedKafkaStreamMetadataProvider.java | 2 +-
.../kafka40}/KafkaAdminClientManagerTest.java | 2 +-
.../KafkaPartitionLevelConnectionHandlerTest.java | 2 +-
.../kafka40}/KafkaPartitionLevelConsumerTest.java | 89 ++-
.../KafkaPartitionLevelStreamConfigTest.java | 25 +-
.../stream/kafka40/utils/MiniKafkaCluster.java | 173 +++++
.../src/test/resources/log4j2.xml | 0
.../pinot-stream-ingestion/pinot-pulsar/pom.xml | 2 +-
.../plugin/stream/pulsar/PulsarConsumerTest.java | 2 +-
pinot-plugins/pinot-stream-ingestion/pom.xml | 2 +-
.../planner/physical/DispatchablePlanContext.java | 3 +
.../apache/pinot/query/routing/WorkerManager.java | 75 ++-
.../pinot/query/routing/WorkerManagerTest.java | 195 ++++++
.../apache/pinot/query/mailbox/MailboxService.java | 151 ++++-
.../query/mailbox/channel/ChannelManager.java | 23 +-
.../query/mailbox/channel/GrpcMailboxServer.java | 18 +-
.../query/runtime/InStageStatsTreeBuilder.java | 85 ++-
.../apache/pinot/query/runtime/QueryRunner.java | 14 +-
.../pinot/query/runtime/context/BrokerContext.java | 55 --
.../query/runtime/context/ControllerContext.java | 33 -
.../pinot/query/runtime/context/ServerContext.java | 55 --
.../query/runtime/operator/BaseJoinOperator.java | 102 +--
.../runtime/operator/EnrichedHashJoinOperator.java | 1 +
.../pinot/query/runtime/operator/LeafOperator.java | 29 +-
.../query/runtime/operator/LookupJoinOperator.java | 11 +-
.../query/runtime/operator/MultiStageOperator.java | 96 ++-
.../runtime/operator/exchange/BlockExchange.java | 17 +-
.../factory/DefaultJoinOperatorFactory.java | 2 +-
.../query/runtime/operator/join/JoinedRowView.java | 124 ++++
.../query/runtime/plan/MultiStageQueryStats.java | 20 +-
.../runtime/plan/OpChainExecutionContext.java | 35 +-
.../query/runtime/plan/PlanNodeToOpChain.java | 12 +-
.../plan/pipeline/PipelineBreakerExecutor.java | 4 +-
.../plan/pipeline/PipelineBreakerOperator.java | 10 +-
.../TimeSeriesExchangeReceiveOperator.java | 25 +-
.../query/service/dispatch/DispatchClient.java | 8 +-
.../query/service/dispatch/QueryDispatcher.java | 24 +-
.../pinot/query/service/server/QueryServer.java | 13 +-
.../apache/pinot/query/QueryServerEnclosure.java | 2 +-
.../executor/OpChainSchedulerServiceTest.java | 2 +-
.../runtime/operator/MailboxSendOperatorTest.java | 2 +-
.../query/runtime/operator/OperatorTestUtil.java | 4 +-
.../plan/pipeline/PipelineBreakerExecutorTest.java | 2 +-
.../local/aggregator/AvgValueAggregator.java | 4 +-
.../local/aggregator/CountMVValueAggregator.java | 11 +-
.../DistinctCountBitmapValueAggregator.java | 18 +-
.../DistinctCountHLLPlusValueAggregator.java | 18 +-
.../DistinctCountHLLValueAggregator.java | 18 +-
.../local/aggregator/MaxValueAggregator.java | 4 +-
.../aggregator/MinMaxRangeValueAggregator.java | 4 +-
.../local/aggregator/MinValueAggregator.java | 4 +-
.../aggregator/PercentileEstValueAggregator.java | 18 +-
.../PercentileTDigestValueAggregator.java | 18 +-
.../local/aggregator/SumValueAggregator.java | 4 +-
.../indexsegment/mutable/MutableSegmentImpl.java | 15 +
.../creator/impl/SegmentDictionaryCreator.java | 27 +-
.../impl/SegmentIndexCreationDriverImpl.java | 5 +-
.../BigDecimalColumnPreIndexStatsCollector.java | 4 +
.../stats/DoubleColumnPreIndexStatsCollector.java | 4 +
.../stats/FloatColumnPreIndexStatsCollector.java | 4 +
.../stats/IntColumnPreIndexStatsCollector.java | 4 +
.../stats/LongColumnPreIndexStatsCollector.java | 4 +
.../stats/MapColumnPreIndexStatsCollector.java | 100 ++-
.../index/dictionary/DictionaryIndexType.java | 4 +-
.../segment/index/loader/ForwardIndexHandler.java | 2 +-
.../defaultcolumn/BaseDefaultColumnHandler.java | 4 +-
.../upsert/BasePartitionUpsertMetadataManager.java | 19 +-
.../pinot/segment/local/upsert/UpsertContext.java | 22 +-
.../segment/local/utils/TableConfigUtils.java | 17 +-
.../stats/MapColumnPreIndexStatsCollectorTest.java | 126 ++++
.../index/creator/CLPForwardIndexCreatorTest.java | 2 +-
.../index/dictionary/DictionaryIndexTypeTest.java | 2 +-
.../segment/local/utils/TableConfigUtilsTest.java | 189 ++++--
.../apache/pinot/segment/spi/SegmentMetadata.java | 9 +
.../segment/spi/index/DictionaryIndexConfig.java | 3 +-
.../pinot/segment/spi/index/TextIndexConfig.java | 45 +-
.../spi/index/metadata/SegmentMetadataImpl.java | 5 +
.../segment/spi/memory/PagedPinotOutputStream.java | 3 +-
.../spi/index/DictionaryIndexConfigTest.java | 10 +-
.../segment/spi/index/TextIndexConfigTest.java | 115 ++++
.../api/resources/ControllerJobStatusResource.java | 5 +
.../pinot/server/api/resources/DebugResource.java | 9 +
.../server/api/resources/InstanceResource.java | 7 +
.../server/api/resources/MmapDebugResource.java | 5 +
.../api/resources/PinotServerAppConfigs.java | 4 +
.../server/api/resources/PinotServerLogger.java | 8 +
.../pinot/server/api/resources/QueryResource.java | 5 +
.../server/api/resources/ReingestionResource.java | 5 +
.../server/api/resources/TableSizeResource.java | 5 +
.../server/api/resources/TableTierResource.java | 5 +
.../pinot/server/api/resources/TablesResource.java | 26 +-
.../pinot/server/starter/ServerInstance.java | 5 +-
.../server/starter/helix/BaseServerStarter.java | 28 +-
.../FreshnessBasedConsumptionStatusChecker.java | 63 +-
.../IngestionBasedConsumptionStatusChecker.java | 25 +-
.../helix/KeepPipelineBreakerStatsPredicate.java | 77 +++
.../pinot/server/worker/WorkerQueryServer.java | 7 +-
...FreshnessBasedConsumptionStatusCheckerTest.java | 300 +++++----
.../OffsetBasedConsumptionStatusCheckerTest.java | 43 ++
.../accounting/ThreadResourceUsageProvider.java | 237 ++++---
.../TableSamplerProvider.java} | 18 +-
.../apache/pinot/spi/audit/AuditTokenResolver.java | 51 ++
.../apache/pinot/spi/audit/AuditUserIdentity.java | 25 +-
.../org/apache/pinot/spi/config/TableConfigs.java | 4 +-
.../apache/pinot/spi/config/table/TableConfig.java | 54 +-
.../TableSamplerConfig.java} | 39 +-
.../apache/pinot/spi/config/user/UserConfig.java | 13 +-
.../java/org/apache/pinot/spi/data/Schema.java | 2 +
.../spi/data/readers/ColumnReaderFactory.java | 18 +
.../apache/pinot/spi/data/readers/FileFormat.java | 18 +-
.../spi/data/readers/RecordReaderFactory.java | 17 +-
.../pinot/spi/ingestion/batch/BatchConfig.java | 2 +-
.../org/apache/pinot/spi/plugin/PluginManager.java | 6 +-
.../spi/stream/StreamDataServerStartable.java | 23 +
.../apache/pinot/spi/utils/CommonConstants.java | 18 +
.../spi/utils/builder/TableConfigBuilder.java | 9 +-
.../spi/config/TableConfigsSerializationTest.java | 292 +++++++++
.../pinot/spi/config/table/TableConfigTest.java | 34 +
.../pinot/spi/config/user/UserConfigTest.java | 176 ++++++
.../pinot/spi/data/SchemaSerializationTest.java | 410 ++++++++++++
.../pinot/spi/data/readers/FileFormatTest.java | 87 +++
.../spi/data/readers/RecordReaderFactoryTest.java | 86 +++
.../apache/pinot/spi/plugin/PluginManagerTest.java | 192 +++++-
.../pinot/tsdb/spi/series/TimeSeriesBlock.java | 4 +-
pinot-tools/pom.xml | 24 -
.../apache/pinot/tools/MultiClusterQuickstart.java | 456 ++++++++++++++
.../org/apache/pinot/tools/QuickStartBase.java | 75 ++-
.../LaunchSparkDataIngestionJobCommand.java | 2 +-
.../tools/admin/command/QuickStartCommand.java | 12 +
.../tools/admin/command/QuickstartRunner.java | 2 +
.../tools/admin/command/StartBrokerCommand.java | 23 +-
.../tools/admin/command/StartKafkaCommand.java | 39 +-
.../admin/command/StartServiceManagerCommand.java | 3 +-
.../tools/admin/command/StopProcessCommand.java | 113 +++-
.../converter/PinotSegmentConvertCommand.java | 2 +-
.../pinot/tools/utils/KafkaStarterUtils.java | 138 ++--
.../apache/pinot/tools/utils/PinotConfigUtils.java | 7 +-
.../conf/sample_realtime_table_config.json | 2 +-
.../airlineStats_offline_table_config.json | 9 +
.../githubEvents_realtime_table_config.json | 2 +-
.../airlineStats_realtime_table_config.json | 2 +-
.../docker/airlineStats_realtime_table_config.json | 2 +-
.../dailySales_realtime_table_config.json | 2 +-
.../fineFoodReviews_realtime_table_config.json | 2 +-
.../githubEvents_realtime_table_config.json | 2 +-
.../meetupRsvp_realtime_table_config.json | 2 +-
...eetupRsvpComplexType_realtime_table_config.json | 2 +-
.../meetupRsvpJson_realtime_table_config.json | 2 +-
...lRequestMergedEvents_realtime_table_config.json | 2 +-
...lRequestMergedEvents_realtime_table_config.json | 2 +-
...upsertJsonMeetupRsvp_realtime_table_config.json | 2 +-
.../upsertMeetupRsvp_realtime_table_config.json | 2 +-
...ertPartialMeetupRsvp_realtime_table_config.json | 2 +-
.../tools/admin/command/TestQuickStartCommand.java | 7 +-
pom.xml | 79 ++-
392 files changed, 15153 insertions(+), 4025 deletions(-)
copy helm/pinot/templates/{controller =>
minion-stateless}/poddisruptionbudget.yaml (59%)
copy helm/pinot/templates/{controller => minion}/poddisruptionbudget.yaml (61%)
create mode 100644
pinot-broker/src/main/java/org/apache/pinot/broker/routing/tablesampler/FirstNSegmentsTableSampler.java
create mode 100644
pinot-broker/src/main/java/org/apache/pinot/broker/routing/tablesampler/TableSampler.java
create mode 100644
pinot-broker/src/main/java/org/apache/pinot/broker/routing/tablesampler/TableSamplerFactory.java
create mode 100644
pinot-broker/src/test/java/org/apache/pinot/broker/routing/tablesampler/TableSamplerFactoryTest.java
copy
pinot-broker/src/{main/java/org/apache/pinot/broker/routing/segmentpreselector/SegmentPreSelectorFactory.java
=>
test/java/org/apache/pinot/broker/routing/tablesampler/external/ExternalAnnotatedSampler.java}
(60%)
create mode 100644
pinot-clients/pinot-java-client/src/main/java/org/apache/pinot/client/DefaultSslContextProvider.java
copy
pinot-segment-spi/src/main/java/org/apache/pinot/segment/spi/creator/name/SegmentNameGenerator.java
=>
pinot-clients/pinot-java-client/src/main/java/org/apache/pinot/client/SslContextProvider.java
(50%)
create mode 100644
pinot-clients/pinot-java-client/src/main/java/org/apache/pinot/client/SslContextProviderFactory.java
create mode 100644
pinot-clients/pinot-java-client/src/test/java/org/apache/pinot/client/SslContextProviderTest.java
create mode 100644
pinot-common/src/test/java/org/apache/pinot/common/audit/MockAuditTokenResolver.java
create mode 100644
pinot-controller/src/main/java/org/apache/pinot/controller/api/resources/TableConfigValidationUtils.java
create mode 100644
pinot-controller/src/test/java/org/apache/pinot/controller/cursors/ResponseStoreCleanerTest.java
create mode 100644
pinot-core/src/main/java/org/apache/pinot/core/instance/context/BrokerContext.java
create mode 100644
pinot-core/src/main/java/org/apache/pinot/core/instance/context/ControllerContext.java
create mode 100644
pinot-core/src/main/java/org/apache/pinot/core/instance/context/ServerContext.java
create mode 100644
pinot-core/src/main/java/org/apache/pinot/core/transport/NettyInspector.java
create mode 100644
pinot-core/src/main/java/org/apache/pinot/core/transport/NettyInstance.java
copy
pinot-core/src/test/java/org/apache/pinot/core/query/aggregation/function/{CountMVAggregationFunctionTest.java
=> DistinctCountBitmapMVAggregationFunctionTest.java} (52%)
copy
pinot-core/src/test/java/org/apache/pinot/core/query/aggregation/function/{CountMVAggregationFunctionTest.java
=> DistinctCountHLLMVAggregationFunctionTest.java} (52%)
copy
pinot-core/src/test/java/org/apache/pinot/core/query/aggregation/function/{CountMVAggregationFunctionTest.java
=> DistinctCountHLLPlusMVAggregationFunctionTest.java} (52%)
copy
pinot-core/src/test/java/org/apache/pinot/core/query/aggregation/function/{CountMVAggregationFunctionTest.java
=> PercentileEstMVAggregationFunctionTest.java} (52%)
copy
pinot-core/src/test/java/org/apache/pinot/core/query/aggregation/function/{CountMVAggregationFunctionTest.java
=> PercentileKLLMVAggregationFunctionTest.java} (52%)
copy
pinot-core/src/test/java/org/apache/pinot/core/query/aggregation/function/{CountMVAggregationFunctionTest.java
=> PercentileMVAggregationFunctionTest.java} (52%)
copy
pinot-core/src/test/java/org/apache/pinot/core/query/aggregation/function/{CountMVAggregationFunctionTest.java
=> PercentileTDigestMVAggregationFunctionTest.java} (52%)
copy
pinot-core/src/test/java/org/apache/pinot/core/startree/v2/{DistinctCountBitmapStarTreeV2Test.java
=> DistinctCountBitmapWithMVStarTreeV2Test.java} (89%)
copy
pinot-core/src/test/java/org/apache/pinot/core/startree/v2/{DistinctCountHLLStarTreeV2Test.java
=> DistinctCountHLLWithMVStarTreeV2Test.java} (90%)
copy
pinot-core/src/test/java/org/apache/pinot/core/startree/v2/{PercentileEstStarTreeV2Test.java
=> PercentileEstWithMVStarTreeV2Test.java} (91%)
copy
pinot-core/src/test/java/org/apache/pinot/core/startree/v2/{PercentileTDigestStarTreeV2Test.java
=> PercentileTDigestWithMVStarTreeV2Test.java} (76%)
create mode 100644
pinot-core/src/test/java/org/apache/pinot/core/transport/DirectOOMHandlerTest.java
copy
pinot-integration-tests/src/test/java/org/apache/pinot/integration/tests/{LLCRealtimeKafka3ClusterIntegrationTest.java
=> LLCRealtimeKafka4ClusterIntegrationTest.java} (89%)
create mode 100644
pinot-integration-tests/src/test/java/org/apache/pinot/integration/tests/PurgeMetadataPushMinionClusterIntegrationTest.java
create mode 100644
pinot-integration-tests/src/test/java/org/apache/pinot/integration/tests/RefreshSegmentMetadataPushMinionClusterIntegrationTest.java
create mode 100644
pinot-integration-tests/src/test/java/org/apache/pinot/integration/tests/custom/MapFieldTypeMixedValueIngestingIntegrationTest.java
create mode 100644
pinot-integration-tests/src/test/java/org/apache/pinot/integration/tests/custom/TableSamplerIntegrationTest.java
create mode 100644
pinot-perf/src/main/java/org/apache/pinot/perf/BenchmarkProtoBufRecordExtractor.java
copy {pinot-plugins/pinot-input-format/pinot-protobuf/src/test =>
pinot-perf/src/main}/resources/complex_types.desc (100%)
create mode 100644
pinot-plugins/pinot-file-system/pinot-s3/src/test/java/org/apache/pinot/plugin/filesystem/S3PinotFSCopyTest.java
create mode 100644
pinot-plugins/pinot-input-format/pinot-protobuf/src/test/java/org/apache/pinot/plugin/inputformat/protobuf/ProtoBufRecordExtractorCachingTest.java
delete mode 100644
pinot-plugins/pinot-stream-ingestion/pinot-kafka-2.0/README.md
delete mode 100644
pinot-plugins/pinot-stream-ingestion/pinot-kafka-2.0/src/main/java/org/apache/pinot/plugin/stream/kafka20/server/KafkaDataServerStartable.java
delete mode 100644
pinot-plugins/pinot-stream-ingestion/pinot-kafka-2.0/src/test/java/org/apache/pinot/plugin/stream/kafka20/KafkaPartitionLevelConsumerBackwardCompatibilityTest.java
delete mode 100644
pinot-plugins/pinot-stream-ingestion/pinot-kafka-2.0/src/test/java/org/apache/pinot/plugin/stream/kafka20/utils/MiniKafkaCluster.java
rename
pinot-plugins/pinot-stream-ingestion/{pinot-kafka-2.0/src/main/java/org/apache/pinot/plugin/stream/kafka20
=>
pinot-kafka-3.0/src/main/java/org/apache/pinot/plugin/stream/kafka30}/server/KafkaDataProducer.java
(92%)
create mode 100644
pinot-plugins/pinot-stream-ingestion/pinot-kafka-3.0/src/main/java/org/apache/pinot/plugin/stream/kafka30/server/KafkaServerStartable.java
rename pinot-plugins/pinot-stream-ingestion/{pinot-kafka-2.0 =>
pinot-kafka-3.0}/src/main/resources/META-INF/services/org.apache.pinot.spi.stream.StreamConsumerFactory
(92%)
create mode 100644
pinot-plugins/pinot-stream-ingestion/pinot-kafka-3.0/src/test/java/org/apache/pinot/plugin/stream/kafka30/server/KafkaServerStartableTest.java
delete mode 100644
pinot-plugins/pinot-stream-ingestion/pinot-kafka-3.0/src/test/java/org/apache/pinot/plugin/stream/kafka30/utils/MiniKafkaCluster.java
rename pinot-plugins/pinot-stream-ingestion/{pinot-kafka-2.0 =>
pinot-kafka-4.0}/pom.xml (81%)
rename
pinot-plugins/pinot-stream-ingestion/{pinot-kafka-2.0/src/main/java/org/apache/pinot/plugin/stream/kafka20
=>
pinot-kafka-4.0/src/main/java/org/apache/pinot/plugin/stream/kafka40}/KafkaConsumerFactory.java
(98%)
rename
pinot-plugins/pinot-stream-ingestion/{pinot-kafka-2.0/src/main/java/org/apache/pinot/plugin/stream/kafka20
=>
pinot-kafka-4.0/src/main/java/org/apache/pinot/plugin/stream/kafka40}/KafkaPartitionLevelConnectionHandler.java
(98%)
rename
pinot-plugins/pinot-stream-ingestion/{pinot-kafka-2.0/src/main/java/org/apache/pinot/plugin/stream/kafka20
=>
pinot-kafka-4.0/src/main/java/org/apache/pinot/plugin/stream/kafka40}/KafkaPartitionLevelConsumer.java
(99%)
rename
pinot-plugins/pinot-stream-ingestion/{pinot-kafka-2.0/src/main/java/org/apache/pinot/plugin/stream/kafka20
=>
pinot-kafka-4.0/src/main/java/org/apache/pinot/plugin/stream/kafka40}/KafkaStreamMetadataProvider.java
(77%)
rename
pinot-plugins/pinot-stream-ingestion/{pinot-kafka-2.0/src/main/java/org/apache/pinot/plugin/stream/kafka20
=>
pinot-kafka-4.0/src/main/java/org/apache/pinot/plugin/stream/kafka40}/SynchronizedKafkaStreamMetadataProvider.java
(97%)
rename
pinot-plugins/pinot-stream-ingestion/{pinot-kafka-2.0/src/test/java/org/apache/pinot/plugin/stream/kafka20
=>
pinot-kafka-4.0/src/test/java/org/apache/pinot/plugin/stream/kafka40}/KafkaAdminClientManagerTest.java
(99%)
rename
pinot-plugins/pinot-stream-ingestion/{pinot-kafka-2.0/src/test/java/org/apache/pinot/plugin/stream/kafka20
=>
pinot-kafka-4.0/src/test/java/org/apache/pinot/plugin/stream/kafka40}/KafkaPartitionLevelConnectionHandlerTest.java
(98%)
rename
pinot-plugins/pinot-stream-ingestion/{pinot-kafka-2.0/src/test/java/org/apache/pinot/plugin/stream/kafka20
=>
pinot-kafka-4.0/src/test/java/org/apache/pinot/plugin/stream/kafka40}/KafkaPartitionLevelConsumerTest.java
(93%)
rename
pinot-plugins/pinot-stream-ingestion/{pinot-kafka-2.0/src/test/java/org/apache/pinot/plugin/stream/kafka20
=>
pinot-kafka-4.0/src/test/java/org/apache/pinot/plugin/stream/kafka40}/KafkaPartitionLevelStreamConfigTest.java
(86%)
create mode 100644
pinot-plugins/pinot-stream-ingestion/pinot-kafka-4.0/src/test/java/org/apache/pinot/plugin/stream/kafka40/utils/MiniKafkaCluster.java
rename pinot-plugins/pinot-stream-ingestion/{pinot-kafka-2.0 =>
pinot-kafka-4.0}/src/test/resources/log4j2.xml (100%)
create mode 100644
pinot-query-planner/src/test/java/org/apache/pinot/query/routing/WorkerManagerTest.java
delete mode 100644
pinot-query-runtime/src/main/java/org/apache/pinot/query/runtime/context/BrokerContext.java
delete mode 100644
pinot-query-runtime/src/main/java/org/apache/pinot/query/runtime/context/ControllerContext.java
delete mode 100644
pinot-query-runtime/src/main/java/org/apache/pinot/query/runtime/context/ServerContext.java
create mode 100644
pinot-query-runtime/src/main/java/org/apache/pinot/query/runtime/operator/join/JoinedRowView.java
create mode 100644
pinot-server/src/main/java/org/apache/pinot/server/starter/helix/KeepPipelineBreakerStatsPredicate.java
copy
pinot-spi/src/main/java/org/apache/pinot/spi/annotations/{minion/EventObserverFactory.java
=> tablesampler/TableSamplerProvider.java} (66%)
create mode 100644
pinot-spi/src/main/java/org/apache/pinot/spi/audit/AuditTokenResolver.java
copy
pinot-query-planner/src/main/java/org/apache/pinot/calcite/rel/rules/TableOptions.java
=> pinot-spi/src/main/java/org/apache/pinot/spi/audit/AuditUserIdentity.java
(61%)
copy
pinot-spi/src/main/java/org/apache/pinot/spi/config/table/{TunerConfig.java =>
sampler/TableSamplerConfig.java} (55%)
create mode 100644
pinot-spi/src/test/java/org/apache/pinot/spi/config/TableConfigsSerializationTest.java
create mode 100644
pinot-spi/src/test/java/org/apache/pinot/spi/config/user/UserConfigTest.java
create mode 100644
pinot-spi/src/test/java/org/apache/pinot/spi/data/SchemaSerializationTest.java
create mode 100644
pinot-spi/src/test/java/org/apache/pinot/spi/data/readers/FileFormatTest.java
create mode 100644
pinot-tools/src/main/java/org/apache/pinot/tools/MultiClusterQuickstart.java
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
