This is an automated email from the ASF dual-hosted git repository.

jamesshao pushed a change to branch upsert-pr-land
in repository https://gitbox.apache.org/repos/asf/incubator-pinot.git.


    from d788680  Merge remote-tracking branch 'upstream/master' into 
upsert-pr-land
     add c969577  update per pr feedback
     add 142a86f  Derive num docs per chunk from max column value length for 
varbyte raw index creator (#5256)
     add e312a93  Pull out all hadoop and spark dependencies into the root pom 
(#5247)
     add a8a0a75  Add icon for the latest release (#5265)
     add 0622d2c  Re-implement ORCRecordReader (#5267)
     add c577088  [TE][subscription] Subscription pipeline should use anomaly 
create ti… (#5233)
     add 713dd1b  Use java.io.tmpdir instead of /tmp (#5270)
     add 78e753b  Fix file not found exception for 
AvroRecordExtractorMapTypeTest (#5272)
     add 7a62166  [TE] Disable alerts if it has no success run within 30 days 
(#5208)
     add bd79861  Issue 5261: Support AggregationFunctions with multiple 
arguments (contd). (#5275)
     add 52472b3  Add access control for Pinot server segment download api. 
(#5260)
     add fb043da  Refactor configs in pinot-spi (#5262)
     add 79cc2a9  Removing the explicit reference to index types in 
segmentDirectory/co… (#5276)
     add 4ed36ff  Remove hadoop dependency in Create Segment Command (#5271)
     add d8a2705  Adding allowVolumeExpansion for volume resizing and updating 
zookeeper chart (#5273)
     add 729f377  Merge branch 'upstream-master' into upsert-pr-land
     add 0f7ce4b  update docs

No new revisions were added by this update.

Summary of changes:
 README.md                                          |   1 +
 kubernetes/helm/charts/zookeeper-2.0.0.tgz         | Bin 10633 -> 0 bytes
 kubernetes/helm/charts/zookeeper-2.1.3.tgz         | Bin 0 -> 10623 bytes
 kubernetes/helm/gke-pd.yaml                        |   1 +
 kubernetes/helm/gke-ssd.yaml                       |   1 +
 kubernetes/helm/requirements.lock                  |   6 +-
 kubernetes/helm/requirements.yaml                  |   2 +-
 .../skaffold/gke/gke-storageclass-kafka-pd.yml     |   1 +
 .../gke/gke-storageclass-pinot-controller-pd.yml   |   1 +
 .../gke/gke-storageclass-pinot-server-pd.yml       |   1 +
 kubernetes/skaffold/gke/gke-storageclass-zk-pd.yml |   1 +
 .../broker/api/resources/PinotBrokerDebug.java     |   2 +-
 ...okerResourceOnlineOfflineStateModelFactory.java |   2 +-
 .../HelixExternalViewBasedQueryQuotaManager.java   |   6 +-
 .../requesthandler/BaseBrokerRequestHandler.java   |  31 +-
 .../pinot/broker/routing/RoutingManager.java       |   4 +-
 .../instanceselector/InstanceSelectorFactory.java  |   6 +-
 .../segmentpruner/SegmentPrunerFactory.java        |  10 +-
 .../segmentselector/SegmentSelectorFactory.java    |   4 +-
 .../routing/timeboundary/TimeBoundaryManager.java  |   4 +-
 .../broker/broker/HelixBrokerStarterTest.java      |   4 +-
 ...elixExternalViewBasedQueryQuotaManagerTest.java |   6 +-
 .../request/PqlAndCalciteSqlCompatibilityTest.java |   5 -
 .../instanceselector/InstanceSelectorTest.java     |   6 +-
 .../routing/segmentpruner/SegmentPrunerTest.java   |  12 +-
 .../segmentselector/SegmentSelectorTest.java       |   4 +-
 .../timeboundary/TimeBoundaryManagerTest.java      |   4 +-
 .../assignment/InstanceAssignmentConfigUtils.java  |  16 +-
 .../common/assignment/InstancePartitionsUtils.java |   6 +-
 .../pinot/common/metadata/ZKMetadataProvider.java  |   4 +-
 .../pinot/common/request/AggregationInfo.java      | 215 ++++++++++++--
 .../apache/pinot/common/utils/CommonConstants.java |   3 +
 .../org/apache/pinot/common/utils/StringUtil.java  |   1 +
 .../pinot/common/utils/config/InstanceUtils.java   |   2 +-
 .../common/utils/config/TableConfigUtils.java      |  40 ++-
 .../pinot/common/utils/config/TagNameUtils.java    |   8 +-
 .../pinot/common/utils/helix/TableCache.java       |   2 +-
 .../common/utils/request/HavingQueryTree.java      |   2 +-
 .../utils/BrokerRequestComparisonUtils.java        |  25 +-
 .../parsers/PinotQuery2BrokerRequestConverter.java |  38 ++-
 .../pql/parsers/pql2/ast/FunctionCallAstNode.java  |  33 +--
 .../common/utils/config/TableConfigSerDeTest.java  |  66 ++---
 .../common/utils/config/TableConfigUtilsTest.java  |   6 +-
 .../common/utils/config/TagNameUtilsTest.java      |   4 +-
 .../apache/pinot/pql/parsers/Pql2CompilerTest.java |  12 +-
 .../pinot/sql/parsers/CalciteSqlCompilerTest.java  | 170 +++++++----
 pinot-common/src/thrift/request.thrift             |   5 +
 .../api/events/DefaultMetadataEventNotifier.java   |   2 +-
 .../api/events/MetadataEventNotifier.java          |   2 +-
 .../pinot/controller/api/resources/Constants.java  |   2 +-
 .../PinotInstanceAssignmentRestletResource.java    |   6 +-
 .../resources/PinotInstanceRestletResource.java    |   2 +-
 .../api/resources/PinotSchemaRestletResource.java  |   2 +-
 .../api/resources/PinotSegmentRestletResource.java |   2 +-
 .../api/resources/PinotTableIndexingConfigs.java   |   2 +-
 .../api/resources/PinotTableInstances.java         |   2 +-
 .../api/resources/PinotTableMetadataConfigs.java   |   2 +-
 .../api/resources/PinotTableRestletResource.java   |   6 +-
 .../api/resources/PinotTableSegmentConfigs.java    |   2 +-
 .../api/resources/PinotTenantRestletResource.java  |   6 +-
 .../pinot/controller/api/resources/TableViews.java |   2 +-
 .../controller/api/upload/SegmentValidator.java    |   2 +-
 .../helix/ControllerRequestURLBuilder.java         |   2 +-
 .../controller/helix/SegmentStatusChecker.java     |   2 +-
 .../helix/core/PinotHelixResourceManager.java      |  18 +-
 .../helix/core/PinotTableIdealStateBuilder.java    |   2 +-
 .../instance/InstanceAssignmentDriver.java         |   8 +-
 .../InstanceReplicaGroupPartitionSelector.java     |   2 +-
 .../instance/InstanceTagPoolSelector.java          |   2 +-
 .../segment/OfflineSegmentAssignment.java          |   6 +-
 .../segment/RealtimeSegmentAssignment.java         |   4 +-
 .../core/assignment/segment/SegmentAssignment.java |   4 +-
 .../segment/SegmentAssignmentFactory.java          |   4 +-
 .../helix/core/minion/ClusterInfoProvider.java     |   2 +-
 .../helix/core/minion/PinotTaskManager.java        |   4 +-
 .../generator/ConvertToRawIndexTaskGenerator.java  |   6 +-
 .../core/minion/generator/PinotTaskGenerator.java  |   2 +-
 .../realtime/PinotLLCRealtimeSegmentManager.java   |   8 +-
 .../core/realtime/PinotRealtimeSegmentManager.java |   4 +-
 .../helix/core/realtime/TableConfigCache.java      |   2 +-
 .../helix/core/rebalance/RebalanceResult.java      |   2 +-
 .../helix/core/rebalance/TableRebalancer.java      |   6 +-
 .../core/relocation/RealtimeSegmentRelocator.java  |   2 +-
 .../helix/core/retention/RetentionManager.java     |   4 +-
 .../controller/util/AutoAddInvertedIndex.java      |   4 +-
 .../controller/util/SegmentIntervalUtils.java      |   2 +-
 .../controller/util/TableRetentionValidator.java   |   4 +-
 .../pinot/controller/util/TableSizeReader.java     |   2 +-
 .../BrokerResourceValidationManager.java           |   2 +-
 .../validation/OfflineSegmentIntervalChecker.java  |   6 +-
 .../RealtimeSegmentValidationManager.java          |   4 +-
 .../controller/validation/StorageQuotaChecker.java |   4 +-
 .../pinot/controller/api/PinotFileUploadTest.java  |   4 +-
 ...PinotInstanceAssignmentRestletResourceTest.java |  16 +-
 .../api/PinotInstanceRestletResourceTest.java      |   4 +-
 .../api/PinotSegmentRestletResourceTest.java       |   4 +-
 .../api/PinotTableRestletResourceTest.java         |   6 +-
 .../api/PinotTenantRestletResourceTest.java        |   2 +-
 .../pinot/controller/api/TableViewsTest.java       |   4 +-
 .../controller/api/upload/ZKOperatorTest.java      |   4 +-
 .../helix/ControllerInstanceToggleTest.java        |   4 +-
 .../controller/helix/ControllerSentinelTestV2.java |   4 +-
 .../pinot/controller/helix/ControllerTest.java     |   4 +-
 .../controller/helix/PinotResourceManagerTest.java |   4 +-
 .../helix/core/PinotHelixResourceManagerTest.java  |  16 +-
 .../instance/InstanceAssignmentTest.java           |  18 +-
 ...fflineNonReplicaGroupSegmentAssignmentTest.java |   6 +-
 .../OfflineReplicaGroupSegmentAssignmentTest.java  |   8 +-
 ...altimeNonReplicaGroupSegmentAssignmentTest.java |   6 +-
 .../RealtimeReplicaGroupSegmentAssignmentTest.java |   6 +-
 .../PinotLLCRealtimeSegmentManagerTest.java        |   6 +-
 .../core/rebalance/TableRebalancerClusterTest.java |  12 +-
 .../helix/core/retention/RetentionManagerTest.java |   4 +-
 .../validation/StorageQuotaCheckerTest.java        |   6 +-
 .../validation/ValidationManagerTest.java          |   4 +-
 .../core/data/manager/BaseTableDataManager.java    |   2 +-
 .../pinot/core/data/manager/TableDataManager.java  |   2 +-
 .../manager/config/TableDataManagerConfig.java     |   4 +-
 .../manager/offline/TableDataManagerProvider.java  |   2 +-
 .../realtime/HLRealtimeSegmentDataManager.java     |   4 +-
 .../realtime/LLRealtimeSegmentDataManager.java     |  10 +-
 .../manager/realtime/RealtimeTableDataManager.java |   4 +-
 .../generator/SegmentGeneratorConfig.java          |  10 +-
 .../indexsegment/mutable/MutableSegmentImpl.java   |   4 +-
 .../impl/v1/VarByteChunkSingleValueReader.java     |   4 +-
 .../impl/v1/VarByteChunkSingleValueWriter.java     |   7 +-
 .../apache/pinot/core/minion/SegmentConverter.java |   2 +-
 .../minion/rollup/MergeRollupSegmentConverter.java |   2 +-
 .../query/DictionaryBasedAggregationOperator.java  |   2 +-
 .../plan/DictionaryBasedAggregationPlanNode.java   |   2 +-
 .../plan/MetadataBasedAggregationPlanNode.java     |   2 +-
 .../apache/pinot/core/plan/TransformPlanNode.java  |   9 +-
 .../core/plan/maker/InstancePlanMakerImplV2.java   |   2 +-
 .../aggregation/AggregationFunctionContext.java    |  36 ++-
 .../aggregation/DefaultAggregationExecutor.java    |  16 +-
 .../aggregation/function/AggregationFunction.java  |   8 +-
 .../function/AggregationFunctionFactory.java       |   5 +-
 .../function/AggregationFunctionUtils.java         |  43 ++-
 .../function/AvgAggregationFunction.java           |  10 +
 .../function/CountAggregationFunction.java         |   4 +-
 .../function/CountMVAggregationFunction.java       |   8 +-
 .../function/DistinctAggregationFunction.java      |  13 +-
 .../function/DistinctCountAggregationFunction.java |  10 +
 .../DistinctCountHLLAggregationFunction.java       |  10 +
 .../DistinctCountRawHLLAggregationFunction.java    |  10 +
 .../function/FastHLLAggregationFunction.java       |  10 +
 .../function/MaxAggregationFunction.java           |  10 +
 .../function/MinAggregationFunction.java           |   9 +
 .../function/MinMaxRangeAggregationFunction.java   |  10 +
 .../function/PercentileAggregationFunction.java    |   8 +-
 .../function/PercentileEstAggregationFunction.java |   8 +-
 .../PercentileEstMVAggregationFunction.java        |   8 +-
 .../function/PercentileMVAggregationFunction.java  |   8 +-
 .../PercentileTDigestAggregationFunction.java      |   8 +-
 .../PercentileTDigestMVAggregationFunction.java    |   8 +-
 .../function/SumAggregationFunction.java           |  10 +
 .../groupby/DefaultGroupByExecutor.java            |   2 +-
 .../query/reduce/DistinctDataTableReducer.java     |  12 +-
 .../core/query/request/ServerQueryRequest.java     |   5 +-
 .../converter/RealtimeSegmentConverter.java        |   4 +-
 .../core/segment/creator/StatsCollectorConfig.java |   2 +-
 .../fwd/SingleValueVarByteRawIndexCreator.java     |  11 +-
 .../segment/index/loader/IndexLoadingConfig.java   |   6 +-
 .../defaultcolumn/BaseDefaultColumnHandler.java    |   3 +-
 .../loader/invertedindex/TextIndexHandler.java     |   4 +-
 .../index/readers/text/LuceneTextIndexReader.java  |   2 +-
 .../core/segment/store/ColumnIndexDirectory.java   |  88 +-----
 .../core/segment/store/FilePerIndexDirectory.java  |  73 +----
 .../segment/store/SegmentLocalFSDirectory.java     |  41 +--
 .../segment/store/SingleFileIndexDirectory.java    |  59 +---
 .../apache/pinot/core/startree/StarTreeUtils.java  |   5 +-
 .../executor/StarTreeAggregationExecutor.java      |   2 +-
 .../startree/executor/StarTreeGroupByExecutor.java |   2 +-
 .../v2/builder/StarTreeV2BuilderConfig.java        |   2 +-
 .../apache/pinot/core/transport/QueryRouter.java   |   2 +-
 .../pinot/core/transport/ServerInstance.java       |   2 +-
 .../core/transport/ServerRoutingInstance.java      |   2 +-
 .../apache/pinot/core/util/ReplicationUtils.java   |   6 +-
 .../realtime/LLRealtimeSegmentDataManagerTest.java |   2 +-
 .../pinot/core/data/table/IndexedTableTest.java    |  41 +--
 .../pinot/core/data/table/TableResizerTest.java    |  27 +-
 .../function/AggregationFunctionFactoryTest.java   | 147 +++++-----
 .../index/creator/SegmentPartitionTest.java        |   4 +-
 .../store/ColumnIndexDirectoryTestHelper.java      |  44 +--
 .../segment/store/FilePerIndexDirectoryTest.java   |  18 +-
 .../store/SingleFileIndexDirectoryTest.java        |  14 +-
 .../pinot/core/transport/QueryRoutingTest.java     |   2 +-
 .../VarByteChunkSingleValueReaderWriteTest.java    |  66 +++++
 .../org/apache/pinot/queries/BaseQueriesTest.java  |   2 +-
 .../apache/pinot/queries/DistinctQueriesTest.java  |   2 +-
 .../DefaultAggregationExecutorTest.java            |   6 +-
 .../AggregationGroupByTrimmingServiceTest.java     |   4 +-
 .../tests/BaseClusterIntegrationTest.java          |   6 +-
 .../pinot/integration/tests/ClusterTest.java       |  14 +-
 .../ControllerPeriodicTasksIntegrationTests.java   |   8 +-
 ...vertToRawIndexMinionClusterIntegrationTest.java |   2 +-
 .../DefaultCommitterRealtimeIntegrationTest.java   |   2 +-
 .../tests/HybridClusterIntegrationTest.java        |   2 +-
 .../tests/LLCRealtimeClusterIntegrationTest.java   |   4 +-
 .../LuceneRealtimeClusterIntegrationTest.java      |   2 +-
 .../tests/OfflineClusterIntegrationTest.java       |   6 +-
 .../tests/SimpleMinionClusterIntegrationTest.java  |   6 +-
 .../apache/pinot/perf/BenchmarkCombineGroupBy.java |  15 +-
 .../apache/pinot/perf/BenchmarkIndexedTable.java   |  16 +-
 .../batch/common/SegmentGenerationTaskRunner.java  |   4 +-
 .../batch/common/SegmentGenerationUtils.java       |   2 +-
 .../pinot-batch-ingestion-hadoop/pom.xml           |  47 +--
 .../pinot-batch-ingestion-spark/pom.xml            |  88 +-----
 .../standalone/SegmentGenerationJobRunner.java     |   2 +-
 .../v0_deprecated/pinot-hadoop/pom.xml             |  38 +--
 .../pinot/hadoop/job/HadoopSegmentCreationJob.java |   4 +-
 .../hadoop/job/HadoopSegmentPreprocessingJob.java  |  12 +-
 .../hadoop/job/mappers/SegmentCreationMapper.java  |   4 +-
 ...mentBuildPushOfflineClusterIntegrationTest.java | 248 ----------------
 .../v0_deprecated/pinot-ingestion-common/pom.xml   |  21 --
 .../pinot/ingestion/common/ControllerRestApi.java  |   2 +-
 .../ingestion/common/DefaultControllerRestApi.java |   2 +-
 .../pinot/ingestion/jobs/BaseSegmentJob.java       |   2 +-
 .../v0_deprecated/pinot-spark/pom.xml              |  32 ---
 .../spark/jobs/SparkSegmentCreationFunction.java   |   4 +-
 .../pinot/spark/jobs/SparkSegmentCreationJob.java  |   4 +-
 .../pinot-batch-ingestion/v0_deprecated/pom.xml    | 105 -------
 pinot-plugins/pinot-file-system/pinot-hdfs/pom.xml |  16 --
 .../avro/AvroRecordExtractorMapTypeTest.java       |  10 +-
 .../inputformat/csv/CSVRecordExtractorTest.java    |   6 +-
 pinot-plugins/pinot-input-format/pinot-orc/pom.xml |  28 +-
 .../plugin/inputformat/orc/ORCRecordExtractor.java | 146 ----------
 .../plugin/inputformat/orc/ORCRecordReader.java    | 320 ++++++++++++++++++---
 .../inputformat/orc/ORCRecordExtractorTest.java    |  94 +++---
 .../inputformat/orc/ORCRecordReaderTest.java       | 219 +++++++-------
 .../pinot-input-format/pinot-parquet/pom.xml       |  16 --
 .../pinot/server/api/access/AccessControl.java     |  31 +-
 .../server/api/access/AccessControlFactory.java    |  15 +-
 .../server/api/access/AllowAllAccessFactory.java   |  21 +-
 .../pinot/server/api/resources/TablesResource.java |  18 ++
 .../server/starter/helix/AdminApiApplication.java  |   6 +-
 .../starter/helix/HelixInstanceDataManager.java    |   2 +-
 .../server/starter/helix/HelixServerStarter.java   |  16 +-
 .../SegmentOnlineOfflineStateModelFactory.java     |   2 +-
 .../apache/pinot/server/api/AccessControlTest.java |  87 ++++++
 .../apache/pinot/server/api/BaseResourceTest.java  |   5 +-
 .../pinot/spi/config/IngestionModeConfig.java      | 152 ----------
 .../org/apache/pinot/spi/config/UpsertConfig.java  |  82 ++++++
 .../spi/config/{api => instance}/Instance.java     |   2 +-
 .../spi/config/{api => instance}/InstanceType.java |   2 +-
 .../config/{ => table}/ColumnPartitionConfig.java  |   3 +-
 .../spi/config/{ => table}/CompletionConfig.java   |   3 +-
 .../pinot/spi/config/{ => table}/FieldConfig.java  |   4 +-
 .../spi/config/{ => table}/IndexingConfig.java     |   4 +-
 .../pinot/spi/config/{ => table}/QueryConfig.java  |   4 +-
 .../pinot/spi/config/{ => table}/QuotaConfig.java  |   4 +-
 .../{ => table}/ReplicaGroupStrategyConfig.java    |   4 +-
 .../spi/config/{ => table}/RoutingConfig.java      |   4 +-
 .../config/{ => table}/SegmentPartitionConfig.java |   4 +-
 .../SegmentsValidationAndRetentionConfig.java      |   4 +-
 .../config/{ => table}/StarTreeIndexConfig.java    |   4 +-
 .../pinot/spi/config/{ => table}/TableConfig.java  |  26 +-
 .../spi/config/{ => table}/TableCustomConfig.java  |   4 +-
 .../spi/config/{ => table}/TableTaskConfig.java    |   4 +-
 .../pinot/spi/config/{ => table}/TableType.java    |   2 +-
 .../spi/config/{ => table}/TagOverrideConfig.java  |   4 +-
 .../pinot/spi/config/{ => table}/TenantConfig.java |   4 +-
 .../assignment/InstanceAssignmentConfig.java       |   2 +-
 .../assignment/InstanceConstraintConfig.java       |   2 +-
 .../assignment/InstancePartitionsType.java         |   2 +-
 .../InstanceReplicaGroupPartitionConfig.java       |   2 +-
 .../assignment/InstanceTagPoolConfig.java          |   2 +-
 .../pinot/spi/config/{api => tenant}/Tenant.java   |   2 +-
 .../spi/config/{api => tenant}/TenantRole.java     |   2 +-
 .../pinot/spi/filesystem/PinotFSFactory.java       |  11 +-
 .../org/apache/pinot/spi/utils/StringUtils.java    |  53 ++++
 .../spi/utils/builder/TableConfigBuilder.java      |  49 ++--
 .../pinot/spi/utils/builder/TableNameBuilder.java  |   2 +-
 .../pinot/spi/config/IndexingConfigTest.java       |   4 +
 .../pinot/spi/config/IngestionModeConfigTest.java  |  93 ------
 .../apache/pinot/spi/config/QuotaConfigTest.java   |   2 +
 .../apache/pinot/spi/config/UpsertConfigTest.java  |  72 +++++
 .../apache/pinot/spi/config/api/TenantTest.java    |   3 +
 .../data/readers/AbstractRecordExtractorTest.java  |  26 +-
 pinot-tools/pom.xml                                |  19 --
 .../org/apache/pinot/tools/HybridQuickstart.java   |   2 +-
 .../apache/pinot/tools/PinotNumReplicaChanger.java |   2 +-
 .../apache/pinot/tools/PinotTableRebalancer.java   |   2 +-
 .../java/org/apache/pinot/tools/Quickstart.java    |   2 +-
 .../apache/pinot/tools/QuickstartTableRequest.java |   2 +-
 .../org/apache/pinot/tools/RealtimeQuickStart.java |   2 +-
 .../org/apache/pinot/tools/UpdateSegmentState.java |   2 +-
 .../tools/admin/command/AddTenantCommand.java      |   4 +-
 .../tools/admin/command/CreateSegmentCommand.java  |  74 ++---
 .../tools/admin/command/MoveReplicaGroup.java      |   2 +-
 .../OfflineSegmentIntervalCheckerCommand.java      |   2 +-
 .../tools/admin/command/QuickstartRunner.java      |   4 +-
 .../command/RealtimeProvisioningHelperCommand.java |   2 +-
 .../tools/admin/command/ValidateConfigCommand.java |   2 +-
 .../config/validator/TableConfigValidator.java     |   2 +-
 .../pinot/tools/perf/PerfBenchmarkDriver.java      |   8 +-
 .../tools/query/comparison/ClusterStarter.java     |   4 +-
 .../realtime/provisioning/MemoryEstimator.java     |   2 +-
 .../apache/pinot/tools/scan/query/Aggregation.java |   4 +-
 .../tools/scan/query/SegmentQueryProcessor.java    |   4 +-
 .../segment/converter/SegmentMergeCommand.java     |   4 +-
 .../githubevents/PullRequestMergedEvent.java       | 209 ++++++--------
 .../PullRequestMergedEventsStream.java             |  73 +++--
 pom.xml                                            | 178 +++++++++++-
 .../anomaly/monitor/MonitorTaskRunner.java         |  65 +++++
 .../datalayer/bao/MergedAnomalyResultManager.java  |   2 +-
 .../bao/jdbc/MergedAnomalyResultManagerImpl.java   |   9 +-
 .../thirdeye/datalayer/dao/GenericPojoDao.java     |   4 +
 .../pinot/thirdeye/datalayer/dto/AbstractDTO.java  |  10 +
 .../datalayer/pojo/DetectionAlertConfigBean.java   |  21 +-
 .../thirdeye/detection/DefaultDataProvider.java    |   3 +
 .../pinot/thirdeye/detection/alert/AlertUtils.java |  10 +-
 .../detection/alert/DetectionAlertJob.java         |  17 +-
 .../detection/alert/DetectionAlertTaskRunner.java  |  24 +-
 .../alert/StatefulDetectionAlertFilter.java        |  50 ++--
 .../filter/DimensionsRecipientAlertFilter.java     |  17 +-
 .../alert/filter/PerUserDimensionAlertFilter.java  |  18 +-
 .../detection/alert/filter/SubscriptionUtils.java  |   1 -
 .../ToAllRecipientsDetectionAlertFilter.java       |  23 +-
 .../components/ThresholdRuleDetector.java          |   2 +-
 .../validators/SubscriptionConfigValidator.java    |   5 -
 .../translator/SubscriptionConfigTranslator.java   |   1 -
 .../thirdeye/detection/alert/SendAlertTest.java    |   8 +-
 .../detection/alert/filter/AlertFilterUtils.java   |  43 +++
 .../filter/DimensionsRecipientAlertFilterTest.java | 149 ++++++----
 .../filter/PerUserDimensionAlertFilterTest.java    |  74 +++--
 .../ToAllRecipientsDetectionAlertFilterTest.java   | 262 +++++++++--------
 327 files changed, 3007 insertions(+), 2996 deletions(-)
 delete mode 100644 kubernetes/helm/charts/zookeeper-2.0.0.tgz
 create mode 100644 kubernetes/helm/charts/zookeeper-2.1.3.tgz
 delete mode 100644 
pinot-plugins/pinot-batch-ingestion/v0_deprecated/pinot-hadoop/src/test/java/org/apache/pinot/integration/tests/HadoopSegmentBuildPushOfflineClusterIntegrationTest.java
 delete mode 100644 
pinot-plugins/pinot-input-format/pinot-orc/src/main/java/org/apache/pinot/plugin/inputformat/orc/ORCRecordExtractor.java
 rename 
pinot-plugins/pinot-input-format/pinot-orc/src/main/java/org/apache/pinot/plugin/inputformat/orc/ORCRecordExtractorConfig.java
 => 
pinot-server/src/main/java/org/apache/pinot/server/api/access/AccessControl.java
 (57%)
 copy pinot-spi/src/main/java/org/apache/pinot/spi/config/TableType.java => 
pinot-server/src/main/java/org/apache/pinot/server/api/access/AccessControlFactory.java
 (73%)
 copy 
pinot-controller/src/main/java/org/apache/pinot/controller/api/events/DefaultMetadataEventNotifier.java
 => 
pinot-server/src/main/java/org/apache/pinot/server/api/access/AllowAllAccessFactory.java
 (65%)
 create mode 100644 
pinot-server/src/test/java/org/apache/pinot/server/api/AccessControlTest.java
 delete mode 100644 
pinot-spi/src/main/java/org/apache/pinot/spi/config/IngestionModeConfig.java
 create mode 100644 
pinot-spi/src/main/java/org/apache/pinot/spi/config/UpsertConfig.java
 rename pinot-spi/src/main/java/org/apache/pinot/spi/config/{api => 
instance}/Instance.java (98%)
 rename pinot-spi/src/main/java/org/apache/pinot/spi/config/{api => 
instance}/InstanceType.java (95%)
 rename pinot-spi/src/main/java/org/apache/pinot/spi/config/{ => 
table}/ColumnPartitionConfig.java (95%)
 rename pinot-spi/src/main/java/org/apache/pinot/spi/config/{ => 
table}/CompletionConfig.java (94%)
 rename pinot-spi/src/main/java/org/apache/pinot/spi/config/{ => 
table}/FieldConfig.java (96%)
 rename pinot-spi/src/main/java/org/apache/pinot/spi/config/{ => 
table}/IndexingConfig.java (98%)
 rename pinot-spi/src/main/java/org/apache/pinot/spi/config/{ => 
table}/QueryConfig.java (95%)
 rename pinot-spi/src/main/java/org/apache/pinot/spi/config/{ => 
table}/QuotaConfig.java (96%)
 rename pinot-spi/src/main/java/org/apache/pinot/spi/config/{ => 
table}/ReplicaGroupStrategyConfig.java (96%)
 rename pinot-spi/src/main/java/org/apache/pinot/spi/config/{ => 
table}/RoutingConfig.java (95%)
 rename pinot-spi/src/main/java/org/apache/pinot/spi/config/{ => 
table}/SegmentPartitionConfig.java (96%)
 rename pinot-spi/src/main/java/org/apache/pinot/spi/config/{ => 
table}/SegmentsValidationAndRetentionConfig.java (97%)
 rename pinot-spi/src/main/java/org/apache/pinot/spi/config/{ => 
table}/StarTreeIndexConfig.java (96%)
 rename pinot-spi/src/main/java/org/apache/pinot/spi/config/{ => 
table}/TableConfig.java (91%)
 rename pinot-spi/src/main/java/org/apache/pinot/spi/config/{ => 
table}/TableCustomConfig.java (93%)
 rename pinot-spi/src/main/java/org/apache/pinot/spi/config/{ => 
table}/TableTaskConfig.java (94%)
 rename pinot-spi/src/main/java/org/apache/pinot/spi/config/{ => 
table}/TableType.java (95%)
 rename pinot-spi/src/main/java/org/apache/pinot/spi/config/{ => 
table}/TagOverrideConfig.java (96%)
 rename pinot-spi/src/main/java/org/apache/pinot/spi/config/{ => 
table}/TenantConfig.java (95%)
 rename pinot-spi/src/main/java/org/apache/pinot/spi/config/{ => 
table}/assignment/InstanceAssignmentConfig.java (98%)
 rename pinot-spi/src/main/java/org/apache/pinot/spi/config/{ => 
table}/assignment/InstanceConstraintConfig.java (96%)
 rename pinot-spi/src/main/java/org/apache/pinot/spi/config/{ => 
table}/assignment/InstancePartitionsType.java (96%)
 rename pinot-spi/src/main/java/org/apache/pinot/spi/config/{ => 
table}/assignment/InstanceReplicaGroupPartitionConfig.java (98%)
 rename pinot-spi/src/main/java/org/apache/pinot/spi/config/{ => 
table}/assignment/InstanceTagPoolConfig.java (97%)
 rename pinot-spi/src/main/java/org/apache/pinot/spi/config/{api => 
tenant}/Tenant.java (98%)
 rename pinot-spi/src/main/java/org/apache/pinot/spi/config/{api => 
tenant}/TenantRole.java (95%)
 create mode 100644 
pinot-spi/src/main/java/org/apache/pinot/spi/utils/StringUtils.java
 delete mode 100644 
pinot-spi/src/test/java/org/apache/pinot/spi/config/IngestionModeConfigTest.java
 create mode 100644 
pinot-spi/src/test/java/org/apache/pinot/spi/config/UpsertConfigTest.java


---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]

Reply via email to