You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pinot.apache.org by jl...@apache.org on 2022/06/08 18:29:50 UTC
[pinot] branch helix-1.0 updated (55c9833350 -> fea5b65420)
This is an automated email from the ASF dual-hosted git repository.
jlli pushed a change to branch helix-1.0
in repository https://gitbox.apache.org/repos/asf/pinot.git
discard 55c9833350 Upgrade Helix to 1.0.3
add 15eae8a49b Not use number of controller addresses as retry count when fetch segment (#8845)
add 041b62f079 Cleanup Kinesis Logs (#8787)
add 810541655f Make PinotClientTransport(Factory) interfaces public (#8841)
add 9f2f1b2bbc Fix multi value column index creation (#8848)
add 8082838ff2 more context info to debug a flaky test (#8853)
add 8a71323c3f Fix Upsert config validation to check for metrics aggregation (#8781)
add dbfe39eaca Fix Configuration Obfuscation test. (#8855)
add 966d828d31 make github action trigger on multi_stage_query_engine branch (#8342)
add ab9e62f94e Add pinot-query-planner module (#8340)
add f1e6a33ab5 add pinot-query-runtime (#8412)
add 8b4309500c Use proto for query plan serialization (#8479)
add 0b41497478 add support for project/filter pushdown (#8558)
add f267e5845d fix rebase issue after PQL deprecation (#8652)
add 57cf9e6f51 [hotfix] fix server discovery (#8664)
add 30e21eb394 row/columnar compatible block (#8583)
add 6b78c9baed [hotfix] multi stage engine serde (#8689)
add b3d704c612 Merge Multistage Engine back to main (#8720)
add 81bda1d26a fix merge conflicts
add ea564f0add Allow appending UUID at end of segment name (#8789)
add bb508919ab Change shading prefix so as to minimize conflicts with other libaries (#8602)
add fea5b65420 Upgrade Helix to 1.0.3
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 (55c9833350)
\
N -- N -- N refs/heads/helix-1.0 (fea5b65420)
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:
pinot-broker/pom.xml | 8 +
.../broker/broker/helix/BaseBrokerStarter.java | 30 +-
.../requesthandler/BaseBrokerRequestHandler.java | 2 +-
.../BrokerRequestHandlerDelegate.java | 84 +++
.../requesthandler/GrpcBrokerRequestHandler.java | 4 +
.../MultiStageBrokerRequestHandler.java | 206 ++++++
.../SingleConnectionBrokerRequestHandler.java | 1 +
.../apache/pinot/client/PinotClientTransport.java | 2 +-
.../pinot/client/PinotClientTransportFactory.java | 2 +-
pinot-common/pom.xml | 6 +-
.../pinot/common/utils/config/InstanceUtils.java | 12 +
.../common/utils/fetcher/HttpSegmentFetcher.java | 5 +-
pinot-common/src/main/proto/mailbox.proto | 55 ++
pinot-common/src/main/proto/plan.proto | 95 +++
pinot-common/src/main/proto/worker.proto | 76 +++
.../common/utils/config/InstanceUtilsTest.java | 26 +-
.../pinot-core-jdk8/pom.xml | 4 +-
.../resources/PinotInstanceRestletResource.java | 28 +
.../api/PinotInstanceRestletResourceTest.java | 15 +-
.../PinotHelixResourceManagerStatelessTest.java | 5 +-
.../helix/core/PinotHelixResourceManagerTest.java | 2 +-
pinot-core/pom.xml | 4 +-
.../pinot/core/transport/ServerInstance.java | 17 +
pinot-distribution/pom.xml | 24 +-
.../tests/OfflineClusterIntegrationTest.java | 8 +-
.../batch/common/SegmentGenerationTaskRunner.java | 14 +-
.../v0_deprecated/pinot-hadoop/pom.xml | 8 +-
.../v0_deprecated/pinot-spark/pom.xml | 8 +-
pinot-plugins/pinot-file-system/pinot-s3/pom.xml | 4 +-
.../pinot-input-format/pinot-avro-base/pom.xml | 4 +-
.../pinot-stream-ingestion/pinot-kafka-0.9/pom.xml | 20 +-
.../pinot-stream-ingestion/pinot-kinesis/pom.xml | 6 +-
.../plugin/stream/kinesis/KinesisConsumer.java | 18 +-
pinot-plugins/pom.xml | 18 +-
pinot-query-planner/pom.xml | 92 +++
.../apache/calcite/jdbc/CalciteSchemaBuilder.java | 52 ++
.../org/apache/pinot/query/QueryEnvironment.java | 193 ++++++
.../apache/pinot/query/catalog/PinotCatalog.java | 122 ++++
.../org/apache/pinot/query/catalog/PinotTable.java | 61 ++
.../apache/pinot/query/context/PlannerContext.java | 25 +-
.../query/parser/CalciteRexExpressionParser.java | 212 +++++++
.../pinot/query/parser/CalciteSqlParser.java | 148 +++++
.../org/apache/pinot/query/parser/ParserUtils.java | 118 ++++
.../apache/pinot/query/parser/QueryRewriter.java | 27 +-
.../apache/pinot/query/planner/PlannerUtils.java | 17 +-
.../org/apache/pinot/query/planner/QueryPlan.java | 61 ++
.../apache/pinot/query/planner/StageMetadata.java | 85 +++
.../query/planner/hints/PinotRelationalHints.java | 19 +-
.../query/planner/logical/LogicalPlanner.java | 63 ++
.../query/planner/logical/RelToStageConverter.java | 108 ++++
.../pinot/query/planner/logical/RexExpression.java | 198 ++++++
.../pinot/query/planner/logical/StagePlanner.java | 135 ++++
.../partitioning/FieldSelectionKeySelector.java | 32 +-
.../query/planner/partitioning/KeySelector.java | 19 +-
.../pinot/query/planner/serde/ProtoProperties.java | 37 +-
.../query/planner/serde/ProtoSerializable.java | 30 +-
.../planner/serde/ProtoSerializationUtils.java | 248 ++++++++
.../query/planner/stage/AbstractStageNode.java | 62 ++
.../pinot/query/planner/stage/FilterNode.java | 31 +-
.../apache/pinot/query/planner/stage/JoinNode.java | 74 +++
.../query/planner/stage/MailboxReceiveNode.java | 42 +-
.../pinot/query/planner/stage/MailboxSendNode.java | 64 ++
.../pinot/query/planner/stage/ProjectNode.java | 50 +-
.../pinot/query/planner/stage/StageNode.java | 31 +-
.../query/planner/stage/StageNodeSerDeUtils.java | 67 ++
.../pinot/query/planner/stage/TableScanNode.java | 41 +-
.../apache/pinot/query/routing/WorkerInstance.java | 56 ++
.../apache/pinot/query/routing/WorkerManager.java | 96 +++
.../query/rules/PinotExchangeNodeInsertRule.java | 102 +++
.../pinot/query/rules/PinotQueryRuleSets.java | 93 +++
.../org/apache/pinot/query/type/TypeFactory.java | 84 +++
.../org/apache/pinot/query/type/TypeSystem.java | 15 +-
.../org/apache/pinot/query/validate/Validator.java | 31 +-
.../apache/pinot/query/QueryEnvironmentTest.java | 103 +++
.../pinot/query/QueryEnvironmentTestBase.java | 52 ++
.../pinot/query/QueryEnvironmentTestUtils.java | 131 ++++
.../pinot/query/planner/stage/SerDeUtilsTest.java | 87 +++
pinot-query-runtime/pom.xml | 83 +++
.../pinot/query/mailbox/GrpcMailboxService.java | 101 +++
.../pinot/query/mailbox/GrpcReceivingMailbox.java | 88 +++
.../pinot/query/mailbox/GrpcSendingMailbox.java | 74 +++
.../pinot/query/mailbox/MailboxIdentifier.java | 38 +-
.../apache/pinot/query/mailbox/MailboxService.java | 70 +++
.../pinot/query/mailbox/ReceivingMailbox.java | 37 +-
.../apache/pinot/query/mailbox/SendingMailbox.java | 30 +-
.../query/mailbox/StringMailboxIdentifier.java | 100 +++
.../java/org/apache/pinot/query/mailbox/Utils.java | 36 +-
.../query/mailbox/channel/ChannelManager.java | 62 ++
.../query/mailbox/channel/GrpcMailboxServer.java | 72 +++
.../channel/MailboxContentStreamObserver.java | 114 ++++
.../channel/MailboxStatusStreamObserver.java | 88 +++
.../apache/pinot/query/runtime/QueryRunner.java | 129 ++++
.../pinot/query/runtime/blocks/BaseDataBlock.java | 697 +++++++++++++++++++++
.../query/runtime/blocks/ColumnarDataBlock.java | 96 +++
.../query/runtime/blocks/DataBlockBuilder.java | 406 ++++++++++++
.../pinot/query/runtime/blocks/DataBlockUtils.java | 174 +++++
.../pinot/query/runtime/blocks/MetadataBlock.java | 66 ++
.../pinot/query/runtime/blocks/RowDataBlock.java | 90 +++
.../query/runtime/blocks/TransferableBlock.java | 76 +++
.../runtime/executor/WorkerQueryExecutor.java | 129 ++++
.../query/runtime/operator/HashJoinOperator.java | 160 +++++
.../runtime/operator/MailboxReceiveOperator.java | 130 ++++
.../runtime/operator/MailboxSendOperator.java | 220 +++++++
.../query/runtime/plan/DistributedStagePlan.java | 76 +++
.../runtime/plan/serde/QueryPlanSerDeUtils.java | 113 ++++
.../query/runtime/utils/ServerRequestUtils.java | 116 ++++
.../apache/pinot/query/service/QueryConfig.java | 22 +-
.../pinot/query/service/QueryDispatcher.java | 160 +++++
.../apache/pinot/query/service/QueryServer.java | 115 ++++
.../apache/pinot/query/QueryServerEnclosure.java | 192 ++++++
.../query/mailbox/GrpcMailboxServiceTest.java | 73 +++
.../query/mailbox/GrpcMailboxServiceTestBase.java | 48 ++
.../pinot/query/runtime/QueryRunnerTest.java | 166 +++++
.../pinot/query/runtime/blocks/DataBlockTest.java | 80 +++
.../query/runtime/blocks/DataBlockTestUtils.java | 181 ++++++
.../pinot/query/service/QueryDispatcherTest.java | 92 +++
.../pinot/query/service/QueryServerTest.java | 182 ++++++
.../creator/impl/SegmentColumnarIndexCreator.java | 84 ++-
.../pinot/segment/local/utils/IngestionUtils.java | 6 +-
.../segment/local/utils/TableConfigUtils.java | 18 +
.../segment/local/utils/TableConfigUtilsTest.java | 99 ++-
.../name/InputFileSegmentNameGenerator.java | 25 +-
.../name/NormalizedDateSegmentNameGenerator.java | 16 +-
.../creator/name/SimpleSegmentNameGenerator.java | 13 +-
pinot-server/pom.xml | 8 +
.../org/apache/pinot/server/conf/ServerConf.java | 14 +
.../pinot/server/starter/ServerInstance.java | 18 +
.../server/starter/helix/BaseServerStarter.java | 8 +
.../pinot/server/worker/WorkerQueryServer.java | 102 +++
pinot-spi/pom.xml | 4 +-
.../apache/pinot/spi/config/instance/Instance.java | 23 +
.../apache/pinot/spi/env/PinotConfiguration.java | 2 +-
.../pinot/spi/ingestion/batch/BatchConfig.java | 7 +
.../spi/ingestion/batch/BatchConfigProperties.java | 2 +
.../apache/pinot/spi/utils/CommonConstants.java | 12 +
.../apache/pinot/spi/config/ConfigUtilsTest.java | 8 +-
pom.xml | 28 +-
137 files changed, 9329 insertions(+), 385 deletions(-)
create mode 100644 pinot-broker/src/main/java/org/apache/pinot/broker/requesthandler/BrokerRequestHandlerDelegate.java
create mode 100644 pinot-broker/src/main/java/org/apache/pinot/broker/requesthandler/MultiStageBrokerRequestHandler.java
create mode 100644 pinot-common/src/main/proto/mailbox.proto
create mode 100644 pinot-common/src/main/proto/plan.proto
create mode 100644 pinot-common/src/main/proto/worker.proto
create mode 100644 pinot-query-planner/pom.xml
create mode 100644 pinot-query-planner/src/main/java/org/apache/calcite/jdbc/CalciteSchemaBuilder.java
create mode 100644 pinot-query-planner/src/main/java/org/apache/pinot/query/QueryEnvironment.java
create mode 100644 pinot-query-planner/src/main/java/org/apache/pinot/query/catalog/PinotCatalog.java
create mode 100644 pinot-query-planner/src/main/java/org/apache/pinot/query/catalog/PinotTable.java
copy pinot-clients/pinot-java-client/src/main/java/org/apache/pinot/client/PinotClientTransportFactory.java => pinot-query-planner/src/main/java/org/apache/pinot/query/context/PlannerContext.java (59%)
create mode 100644 pinot-query-planner/src/main/java/org/apache/pinot/query/parser/CalciteRexExpressionParser.java
create mode 100644 pinot-query-planner/src/main/java/org/apache/pinot/query/parser/CalciteSqlParser.java
create mode 100644 pinot-query-planner/src/main/java/org/apache/pinot/query/parser/ParserUtils.java
copy pinot-clients/pinot-java-client/src/main/java/org/apache/pinot/client/PinotClientTransportFactory.java => pinot-query-planner/src/main/java/org/apache/pinot/query/parser/QueryRewriter.java (51%)
copy pinot-clients/pinot-java-client/src/main/java/org/apache/pinot/client/PinotClientTransportFactory.java => pinot-query-planner/src/main/java/org/apache/pinot/query/planner/PlannerUtils.java (75%)
create mode 100644 pinot-query-planner/src/main/java/org/apache/pinot/query/planner/QueryPlan.java
create mode 100644 pinot-query-planner/src/main/java/org/apache/pinot/query/planner/StageMetadata.java
copy pinot-clients/pinot-java-client/src/main/java/org/apache/pinot/client/PinotClientTransportFactory.java => pinot-query-planner/src/main/java/org/apache/pinot/query/planner/hints/PinotRelationalHints.java (62%)
create mode 100644 pinot-query-planner/src/main/java/org/apache/pinot/query/planner/logical/LogicalPlanner.java
create mode 100644 pinot-query-planner/src/main/java/org/apache/pinot/query/planner/logical/RelToStageConverter.java
create mode 100644 pinot-query-planner/src/main/java/org/apache/pinot/query/planner/logical/RexExpression.java
create mode 100644 pinot-query-planner/src/main/java/org/apache/pinot/query/planner/logical/StagePlanner.java
copy pinot-clients/pinot-java-client/src/main/java/org/apache/pinot/client/PinotClientTransportFactory.java => pinot-query-planner/src/main/java/org/apache/pinot/query/planner/partitioning/FieldSelectionKeySelector.java (56%)
copy pinot-clients/pinot-java-client/src/main/java/org/apache/pinot/client/PinotClientTransportFactory.java => pinot-query-planner/src/main/java/org/apache/pinot/query/planner/partitioning/KeySelector.java (60%)
copy pinot-clients/pinot-java-client/src/main/java/org/apache/pinot/client/PinotClientTransport.java => pinot-query-planner/src/main/java/org/apache/pinot/query/planner/serde/ProtoProperties.java (54%)
copy pinot-clients/pinot-java-client/src/main/java/org/apache/pinot/client/PinotClientTransportFactory.java => pinot-query-planner/src/main/java/org/apache/pinot/query/planner/serde/ProtoSerializable.java (50%)
create mode 100644 pinot-query-planner/src/main/java/org/apache/pinot/query/planner/serde/ProtoSerializationUtils.java
create mode 100644 pinot-query-planner/src/main/java/org/apache/pinot/query/planner/stage/AbstractStageNode.java
copy pinot-clients/pinot-java-client/src/main/java/org/apache/pinot/client/PinotClientTransportFactory.java => pinot-query-planner/src/main/java/org/apache/pinot/query/planner/stage/FilterNode.java (57%)
create mode 100644 pinot-query-planner/src/main/java/org/apache/pinot/query/planner/stage/JoinNode.java
copy pinot-clients/pinot-java-client/src/main/java/org/apache/pinot/client/PinotClientTransport.java => pinot-query-planner/src/main/java/org/apache/pinot/query/planner/stage/MailboxReceiveNode.java (52%)
create mode 100644 pinot-query-planner/src/main/java/org/apache/pinot/query/planner/stage/MailboxSendNode.java
copy pinot-clients/pinot-java-client/src/main/java/org/apache/pinot/client/PinotClientTransport.java => pinot-query-planner/src/main/java/org/apache/pinot/query/planner/stage/ProjectNode.java (53%)
copy pinot-clients/pinot-java-client/src/main/java/org/apache/pinot/client/PinotClientTransport.java => pinot-query-planner/src/main/java/org/apache/pinot/query/planner/stage/StageNode.java (53%)
create mode 100644 pinot-query-planner/src/main/java/org/apache/pinot/query/planner/stage/StageNodeSerDeUtils.java
copy pinot-clients/pinot-java-client/src/main/java/org/apache/pinot/client/PinotClientTransport.java => pinot-query-planner/src/main/java/org/apache/pinot/query/planner/stage/TableScanNode.java (54%)
create mode 100644 pinot-query-planner/src/main/java/org/apache/pinot/query/routing/WorkerInstance.java
create mode 100644 pinot-query-planner/src/main/java/org/apache/pinot/query/routing/WorkerManager.java
create mode 100644 pinot-query-planner/src/main/java/org/apache/pinot/query/rules/PinotExchangeNodeInsertRule.java
create mode 100644 pinot-query-planner/src/main/java/org/apache/pinot/query/rules/PinotQueryRuleSets.java
create mode 100644 pinot-query-planner/src/main/java/org/apache/pinot/query/type/TypeFactory.java
copy pinot-clients/pinot-java-client/src/main/java/org/apache/pinot/client/PinotClientTransportFactory.java => pinot-query-planner/src/main/java/org/apache/pinot/query/type/TypeSystem.java (75%)
copy pinot-clients/pinot-java-client/src/main/java/org/apache/pinot/client/PinotClientTransport.java => pinot-query-planner/src/main/java/org/apache/pinot/query/validate/Validator.java (54%)
create mode 100644 pinot-query-planner/src/test/java/org/apache/pinot/query/QueryEnvironmentTest.java
create mode 100644 pinot-query-planner/src/test/java/org/apache/pinot/query/QueryEnvironmentTestBase.java
create mode 100644 pinot-query-planner/src/test/java/org/apache/pinot/query/QueryEnvironmentTestUtils.java
create mode 100644 pinot-query-planner/src/test/java/org/apache/pinot/query/planner/stage/SerDeUtilsTest.java
create mode 100644 pinot-query-runtime/pom.xml
create mode 100644 pinot-query-runtime/src/main/java/org/apache/pinot/query/mailbox/GrpcMailboxService.java
create mode 100644 pinot-query-runtime/src/main/java/org/apache/pinot/query/mailbox/GrpcReceivingMailbox.java
create mode 100644 pinot-query-runtime/src/main/java/org/apache/pinot/query/mailbox/GrpcSendingMailbox.java
copy pinot-clients/pinot-java-client/src/main/java/org/apache/pinot/client/PinotClientTransportFactory.java => pinot-query-runtime/src/main/java/org/apache/pinot/query/mailbox/MailboxIdentifier.java (54%)
create mode 100644 pinot-query-runtime/src/main/java/org/apache/pinot/query/mailbox/MailboxService.java
copy pinot-clients/pinot-java-client/src/main/java/org/apache/pinot/client/PinotClientTransportFactory.java => pinot-query-runtime/src/main/java/org/apache/pinot/query/mailbox/ReceivingMailbox.java (55%)
copy pinot-clients/pinot-java-client/src/main/java/org/apache/pinot/client/PinotClientTransportFactory.java => pinot-query-runtime/src/main/java/org/apache/pinot/query/mailbox/SendingMailbox.java (57%)
create mode 100644 pinot-query-runtime/src/main/java/org/apache/pinot/query/mailbox/StringMailboxIdentifier.java
copy pinot-clients/pinot-java-client/src/main/java/org/apache/pinot/client/PinotClientTransport.java => pinot-query-runtime/src/main/java/org/apache/pinot/query/mailbox/Utils.java (54%)
create mode 100644 pinot-query-runtime/src/main/java/org/apache/pinot/query/mailbox/channel/ChannelManager.java
create mode 100644 pinot-query-runtime/src/main/java/org/apache/pinot/query/mailbox/channel/GrpcMailboxServer.java
create mode 100644 pinot-query-runtime/src/main/java/org/apache/pinot/query/mailbox/channel/MailboxContentStreamObserver.java
create mode 100644 pinot-query-runtime/src/main/java/org/apache/pinot/query/mailbox/channel/MailboxStatusStreamObserver.java
create mode 100644 pinot-query-runtime/src/main/java/org/apache/pinot/query/runtime/QueryRunner.java
create mode 100644 pinot-query-runtime/src/main/java/org/apache/pinot/query/runtime/blocks/BaseDataBlock.java
create mode 100644 pinot-query-runtime/src/main/java/org/apache/pinot/query/runtime/blocks/ColumnarDataBlock.java
create mode 100644 pinot-query-runtime/src/main/java/org/apache/pinot/query/runtime/blocks/DataBlockBuilder.java
create mode 100644 pinot-query-runtime/src/main/java/org/apache/pinot/query/runtime/blocks/DataBlockUtils.java
create mode 100644 pinot-query-runtime/src/main/java/org/apache/pinot/query/runtime/blocks/MetadataBlock.java
create mode 100644 pinot-query-runtime/src/main/java/org/apache/pinot/query/runtime/blocks/RowDataBlock.java
create mode 100644 pinot-query-runtime/src/main/java/org/apache/pinot/query/runtime/blocks/TransferableBlock.java
create mode 100644 pinot-query-runtime/src/main/java/org/apache/pinot/query/runtime/executor/WorkerQueryExecutor.java
create mode 100644 pinot-query-runtime/src/main/java/org/apache/pinot/query/runtime/operator/HashJoinOperator.java
create mode 100644 pinot-query-runtime/src/main/java/org/apache/pinot/query/runtime/operator/MailboxReceiveOperator.java
create mode 100644 pinot-query-runtime/src/main/java/org/apache/pinot/query/runtime/operator/MailboxSendOperator.java
create mode 100644 pinot-query-runtime/src/main/java/org/apache/pinot/query/runtime/plan/DistributedStagePlan.java
create mode 100644 pinot-query-runtime/src/main/java/org/apache/pinot/query/runtime/plan/serde/QueryPlanSerDeUtils.java
create mode 100644 pinot-query-runtime/src/main/java/org/apache/pinot/query/runtime/utils/ServerRequestUtils.java
copy pinot-clients/pinot-java-client/src/main/java/org/apache/pinot/client/PinotClientTransportFactory.java => pinot-query-runtime/src/main/java/org/apache/pinot/query/service/QueryConfig.java (55%)
create mode 100644 pinot-query-runtime/src/main/java/org/apache/pinot/query/service/QueryDispatcher.java
create mode 100644 pinot-query-runtime/src/main/java/org/apache/pinot/query/service/QueryServer.java
create mode 100644 pinot-query-runtime/src/test/java/org/apache/pinot/query/QueryServerEnclosure.java
create mode 100644 pinot-query-runtime/src/test/java/org/apache/pinot/query/mailbox/GrpcMailboxServiceTest.java
create mode 100644 pinot-query-runtime/src/test/java/org/apache/pinot/query/mailbox/GrpcMailboxServiceTestBase.java
create mode 100644 pinot-query-runtime/src/test/java/org/apache/pinot/query/runtime/QueryRunnerTest.java
create mode 100644 pinot-query-runtime/src/test/java/org/apache/pinot/query/runtime/blocks/DataBlockTest.java
create mode 100644 pinot-query-runtime/src/test/java/org/apache/pinot/query/runtime/blocks/DataBlockTestUtils.java
create mode 100644 pinot-query-runtime/src/test/java/org/apache/pinot/query/service/QueryDispatcherTest.java
create mode 100644 pinot-query-runtime/src/test/java/org/apache/pinot/query/service/QueryServerTest.java
create mode 100644 pinot-server/src/main/java/org/apache/pinot/server/worker/WorkerQueryServer.java
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@pinot.apache.org
For additional commands, e-mail: commits-help@pinot.apache.org