This is an automated email from the ASF dual-hosted git repository.
jihao pushed a change to branch alert-searcher-fix
in repository https://gitbox.apache.org/repos/asf/incubator-pinot.git.
discard b426baa [TE] alert search - allow search by both metrics and datasets
add 32feeb3 Fix double memory allocation during operator setup (#5619)
add a5de96c [TE] logging config change for demo mode (#5621)
add e3d41db Add log for reloading single segment (#5622)
add 9e913ad [TE] Upgrade Pinot version to 0.4.0 (#5618)
add 33f5dd7 [TE] fix run-backend.sh with log4j2 (#5629)
add c2a6a5d Upgrade pinotdb lib in Superset image (#5634)
add bd5957a adding close connnection method (#5633)
add a3faa2f Change a NPE to have a better error message (#5482)
add 1d9135b [QueryContext] Use QueryContext in functions (#5613)
add 5300197 Remove updateExistedSegment (#5636)
add 346af79 [TE] alert search - allow search by both metrics and datasets
add e860058 address comments
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 (b426baa)
\
N -- N -- N refs/heads/alert-searcher-fix (e860058)
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:
docker/images/pinot-superset/requirements-db.txt | 2 +-
.../requesthandler/BaseBrokerRequestHandler.java | 2 +-
.../java/org/apache/pinot/client/Connection.java | 10 +
.../client/JsonAsyncHttpPinotClientTransport.java | 20 +-
.../apache/pinot/client/PinotClientTransport.java | 3 +
.../apache/pinot/client/PreparedStatementTest.java | 6 +
.../apache/pinot/client/ResultSetGroupTest.java | 6 +
.../common/utils/request/FilterQueryTree.java | 11 -
.../pinot/common/utils/request/RequestUtils.java | 60 ---
.../helix/core/PinotHelixResourceManager.java | 136 +----
.../core/common/datatable/DataTableUtils.java | 40 +-
.../data/function/InbuiltFunctionEvaluator.java | 41 +-
.../immutable/ImmutableSegmentImpl.java | 6 +-
.../core/operator/CombineGroupByOperator.java | 3 +-
.../operator/CombineGroupByOrderByOperator.java | 3 +-
.../pinot/core/operator/ProjectionOperator.java | 9 +-
.../core/operator/blocks/MultiValueBlock.java | 10 +-
.../core/operator/blocks/ProjectionBlock.java | 14 +-
.../core/operator/blocks/SingleValueBlock.java | 8 +-
.../pinot/core/operator/blocks/TransformBlock.java | 17 +-
.../operator/filter/ExpressionFilterOperator.java | 2 +-
.../operator/query/AggregationGroupByOperator.java | 11 +-
.../query/AggregationGroupByOrderByOperator.java | 12 +-
.../core/operator/query/AggregationOperator.java | 1 +
.../query/DictionaryBasedAggregationOperator.java | 5 +-
.../operator/query/EmptySelectionOperator.java | 11 +-
.../query/MetadataBasedAggregationOperator.java | 1 +
.../core/operator/query/SelectionOnlyOperator.java | 10 +-
.../operator/query/SelectionOrderByOperator.java | 17 +-
.../core/operator/transform/TransformOperator.java | 14 +-
.../function/TransformFunctionFactory.java | 29 +-
.../plan/AggregationGroupByOrderByPlanNode.java | 13 +-
.../core/plan/AggregationGroupByPlanNode.java | 13 +-
.../pinot/core/plan/AggregationPlanNode.java | 6 +-
.../plan/DictionaryBasedAggregationPlanNode.java | 6 +-
.../plan/MetadataBasedAggregationPlanNode.java | 6 +-
.../apache/pinot/core/plan/SelectionPlanNode.java | 42 +-
.../apache/pinot/core/plan/TransformPlanNode.java | 67 +--
.../aggregation/function/AggregationFunction.java | 12 +-
.../function/AggregationFunctionFactory.java | 100 ++--
.../function/AggregationFunctionUtils.java | 79 ++-
.../function/AvgAggregationFunction.java | 12 +-
.../function/AvgMVAggregationFunction.java | 12 +-
.../BaseSingleInputAggregationFunction.java | 18 +-
.../function/CountAggregationFunction.java | 15 +-
.../function/CountMVAggregationFunction.java | 24 +-
.../function/DistinctAggregationFunction.java | 61 ++-
.../function/DistinctCountAggregationFunction.java | 12 +-
.../DistinctCountHLLAggregationFunction.java | 17 +-
.../DistinctCountHLLMVAggregationFunction.java | 10 +-
.../DistinctCountMVAggregationFunction.java | 12 +-
.../DistinctCountRawHLLAggregationFunction.java | 14 +-
.../DistinctCountRawHLLMVAggregationFunction.java | 3 +-
...inctCountRawThetaSketchAggregationFunction.java | 16 +-
...istinctCountThetaSketchAggregationFunction.java | 575 +++++++++------------
.../function/FastHLLAggregationFunction.java | 12 +-
.../function/MaxAggregationFunction.java | 12 +-
.../function/MaxMVAggregationFunction.java | 12 +-
.../function/MinAggregationFunction.java | 12 +-
.../function/MinMVAggregationFunction.java | 12 +-
.../function/MinMaxRangeAggregationFunction.java | 12 +-
.../function/MinMaxRangeMVAggregationFunction.java | 12 +-
.../function/PercentileAggregationFunction.java | 16 +-
.../function/PercentileEstAggregationFunction.java | 16 +-
.../PercentileEstMVAggregationFunction.java | 16 +-
.../function/PercentileMVAggregationFunction.java | 16 +-
.../PercentileTDigestAggregationFunction.java | 16 +-
.../PercentileTDigestMVAggregationFunction.java | 16 +-
.../function/SumAggregationFunction.java | 12 +-
.../function/SumMVAggregationFunction.java | 12 +-
.../function/customobject/DistinctTable.java | 14 +-
.../groupby/DefaultGroupByExecutor.java | 11 +-
.../groupby/DictionaryBasedGroupKeyGenerator.java | 26 +-
.../aggregation/groupby/GroupKeyGenerator.java | 5 +-
.../NoDictionaryMultiColumnGroupKeyGenerator.java | 16 +-
.../NoDictionarySingleColumnGroupKeyGenerator.java | 13 +-
.../query/executor/ServerQueryExecutorV1Impl.java | 2 +-
.../query/reduce/DistinctDataTableReducer.java | 40 +-
.../core/query/reduce/ResultReducerFactory.java | 6 +-
.../query/request/context/ExpressionContext.java | 27 -
.../BrokerRequestToQueryContextConverter.java | 9 +-
.../context/utils/QueryContextConverterUtils.java | 22 +
.../query/selection/SelectionOperatorUtils.java | 67 +--
.../apache/pinot/core/startree/StarTreeUtils.java | 7 +-
.../startree/executor/StarTreeGroupByExecutor.java | 9 +-
.../startree/plan/StarTreeTransformPlanNode.java | 16 +-
.../startree/v2/AggregationFunctionColumnPair.java | 11 +-
.../core/common/datatable/DataTableUtilsTest.java | 29 +-
.../pinot/core/data/table/IndexedTableTest.java | 13 +-
.../pinot/core/data/table/TableResizerTest.java | 7 +-
.../core/operator/CombineSlowOperatorsTest.java | 21 +-
.../function/AdditionTransformFunctionTest.java | 9 +-
.../function/ArrayLengthTransformFunctionTest.java | 16 +-
.../BinaryOperatorTransformFunctionTest.java | 25 +-
.../function/CaseTransformFunctionTest.java | 20 +-
.../function/CastTransformFunctionTest.java | 13 +-
.../DateTimeConversionTransformFunctionTest.java | 7 +-
.../function/DateTruncTransformFunctionTest.java | 83 +--
.../function/DivisionTransformFunctionTest.java | 23 +-
.../JsonExtractScalarTransformFunctionTest.java | 34 +-
.../function/ModuloTransformFunctionTest.java | 23 +-
.../MultiplicationTransformFunctionTest.java | 9 +-
.../ScalarTransformFunctionWrapperTest.java | 50 +-
.../SingleParamMathTransformFunctionTest.java | 104 ++--
.../function/SubtractionTransformFunctionTest.java | 23 +-
.../TimeConversionTransformFunctionTest.java | 13 +-
.../function/ValueInTransformFunctionTest.java | 7 +-
.../pinot/core/plan/CombinePlanNodeTest.java | 6 +-
...adataAndDictionaryAggregationPlanMakerTest.java | 11 +-
.../function/AggregationFunctionFactoryTest.java | 443 +++++++---------
.../query/pruner/ColumnValueSegmentPrunerTest.java | 8 +-
.../BrokerRequestToQueryContextConverterTest.java | 41 +-
.../pinot/core/startree/v2/BaseStarTreeV2Test.java | 23 +-
.../org/apache/pinot/queries/BaseQueriesTest.java | 4 +-
.../queries/DistinctCountThetaSketchTest.java | 15 +-
.../apache/pinot/queries/DistinctQueriesTest.java | 4 +-
.../DefaultAggregationExecutorTest.java | 26 +-
.../AggregationGroupByTrimmingServiceTest.java | 23 +-
.../DictionaryBasedGroupKeyGeneratorTest.java | 32 +-
.../groupby/NoDictionaryGroupKeyGeneratorTest.java | 23 +-
.../selection/SelectionOperatorServiceTest.java | 37 +-
.../apache/pinot/perf/BenchmarkCombineGroupBy.java | 9 +-
.../apache/pinot/perf/BenchmarkIndexedTable.java | 9 +-
.../starter/helix/HelixInstanceDataManager.java | 1 +
.../pinot/spi/config/table/TableCustomConfig.java | 2 -
thirdeye/docs/pinot.rst | 4 +-
thirdeye/install.sh | 2 +-
thirdeye/pom.xml | 15 +-
thirdeye/run-backend.sh | 2 +-
thirdeye/run-frontend.sh | 2 +-
.../app/pods/manage/alerts/index/controller.js | 5 +-
.../app/pods/manage/alerts/index/route.js | 8 +-
thirdeye/thirdeye-pinot/config/dashboard.yml | 4 +
thirdeye/thirdeye-pinot/config/detector.yml | 6 +-
thirdeye/thirdeye-pinot/pom.xml | 6 +-
.../onboard/AutoOnboardPinotMetadataSource.java | 95 ++--
.../auto/onboard/AutoOnboardPinotMetricsUtils.java | 75 +--
.../thirdeye/auto/onboard/ConfigGenerator.java | 44 +-
.../pinot/thirdeye/common/time/TimeSpec.java | 6 +-
.../resources/v2/alerts/AlertResource.java | 2 +
.../apache/pinot/thirdeye/dataframe/DataFrame.java | 4 +-
.../pinot/thirdeye/datasource/pinot/PqlUtils.java | 12 +-
.../pinot/thirdeye/datasource/sql/SqlUtils.java | 8 +-
.../pinot/thirdeye/detection/ModelRetuneFlow.java | 1 -
.../apache/pinot/thirdeye/util/ThirdEyeUtils.java | 6 +-
.../src/main/resources/log4j2-test.xml | 13 -
.../thirdeye-pinot/src/main/resources/log4j2.xml | 16 +
.../AutoOnboardPinotMetricsServiceTest.java | 63 +--
.../thirdeye/datasource/pinot/PqlUtilsTest.java | 4 +-
149 files changed, 1678 insertions(+), 2141 deletions(-)
delete mode 100644 thirdeye/thirdeye-pinot/src/main/resources/log4j2-test.xml
create mode 100644 thirdeye/thirdeye-pinot/src/main/resources/log4j2.xml
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
