This is an automated email from the ASF dual-hosted git repository.
jlli pushed a change to branch add-logic-for-lead-controller-resource
in repository https://gitbox.apache.org/repos/asf/incubator-pinot.git.
discard 2bb1476 Add logic for lead controller resource on controller side
discard d07e0ba Add logic for leveraging lead controller resource
add 1257a35 Clean up table name access for StorageQuotaChecker (#4302)
add 753801a [TE] Dispaly alert description in alert emails (#4292)
add c4e1ac9 [TE] Auto-Resolving Create-Update API for alerts (#4295)
add 23cb9ed [TE] Improve log debugging - leverage logback capabilities to
log thread id; make logging class concise (#4291)
add d4474b9 [TE] populate the feedback in DTO for child anomalies (#4301)
add 6c4138f [TE] Detection model maintenance flow (#4266)
add 38a1804 [TE] Translator code refactor to accommodate entity config
translation (#4286)
add 4c3be2d [TE] add path for create/update api (#4305)
add baca816 Adding example of querying BYTES column (#4304)
add 2a4b425 [TE] Clean up exceptions in Yaml Resource (#4303)
add 9f3fe4e PQL -> SQL enhancement - phase 1 - new Pinot Query Struct
(#4216)
add c238c2b Added tests for RealtimeSegmentValidationManager (#4306)
add c7e2481 [TE] frontend - harleyjj/screenshot - Adds bounds to
Screenshot and Anomalies route (#4300)
add 27ad26c Adding script to build and publish docker image (#4200)
add 8b45b8f Prepare licenses for 0.2 (#4290)
add 891b31c [TE] frontend - harleyjj/alerts - refactor alerts controller
to maintain consistent state (#4299)
add 5390395 Adding ORC configuration in docs (#4045)
add e397731 [TE] Propagate diagnostics and evaluations from
AnoamlyFilterWrapper (#4315)
add fc4165d [TE] Revert HTTPS redirect (#4316)
add 2e543e9 Add interface and implementations for the new segment
assignment (#4269)
add eee245e [TE] Use multimap in metric urn as dimension (#4313)
new e87ee39 Add logic for leveraging lead controller resource
new df041cb Add logic for lead controller resource on controller side
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 (2bb1476)
\
N -- N -- N refs/heads/add-logic-for-lead-controller-resource
(df041cb)
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.
The 2 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
LICENSE-binary | 263 +--
NOTICE-binary | 771 +++++----
docker/Dockerfile | 62 +
docker/README.md | 116 ++
docker/docker-build-and-push.sh | 30 +
docker/docker-build.sh | 47 +
docker/docker-push.sh | 29 +
docs/pql_examples.rst | 13 +-
docs/record_reader.rst | 11 +
licenses-binary/LICENSE-aopalliance.txt | 2 +
licenses-binary/LICENSE-asm.txt | 27 +
licenses-binary/LICENSE-esotericsoftware.txt | 11 +
licenses-binary/LICENSE-jcraft.txt | 32 +
licenses-binary/LICENSE-protobuf.txt | 32 +
licenses-binary/LICENSE-xmlenc.txt | 27 +
pinot-common/pom.xml | 7 +
.../pinot/common/metadata/ZKMetadataProvider.java | 4 +-
.../pinot/common/request/AggregationInfo.java | 6 +-
.../apache/pinot/common/request/BrokerRequest.java | 133 +-
.../request/{QuerySource.java => DataSource.java} | 61 +-
.../apache/pinot/common/request/Expression.java | 774 +++++++++
.../{FilterOperator.java => ExpressionType.java} | 31 +-
.../pinot/common/request/FilterOperator.java | 2 +-
.../apache/pinot/common/request/FilterQuery.java | 6 +-
.../pinot/common/request/FilterQueryMap.java | 4 +-
.../Function.java} | 365 ++--
.../org/apache/pinot/common/request/GroupBy.java | 70 +-
.../pinot/common/request/HavingFilterQuery.java | 6 +-
.../pinot/common/request/HavingFilterQueryMap.java | 4 +-
.../request/{QuerySource.java => Identifier.java} | 200 +--
.../pinot/common/request/InstanceRequest.java | 40 +-
.../org/apache/pinot/common/request/Literal.java | 771 +++++++++
.../apache/pinot/common/request/PinotQuery.java | 1807 ++++++++++++++++++++
.../apache/pinot/common/request/QuerySource.java | 4 +-
.../org/apache/pinot/common/request/QueryType.java | 14 +-
.../org/apache/pinot/common/request/Selection.java | 76 +-
.../apache/pinot/common/request/SelectionSort.java | 6 +-
.../pinot/common/response/ProcessingException.java | 6 +-
.../utils/InstancePartitionsType.java} | 26 +-
.../java/org/apache/pinot/common/utils/Pairs.java | 37 +-
.../pinot/common/utils/request/RequestUtils.java | 99 +-
.../parsers/PinotQuery2BrokerRequestConverter.java | 354 ++++
.../org/apache/pinot/pql/parsers/Pql2Compiler.java | 98 +-
.../apache/pinot/pql/parsers/pql2/ast/AstNode.java | 5 +
.../pinot/pql/parsers/pql2/ast/BaseAstNode.java | 14 +
.../parsers/pql2/ast/BetweenPredicateAstNode.java | 31 +-
.../parsers/pql2/ast/BooleanOperatorAstNode.java | 10 +
.../pql2/ast/ComparisonPredicateAstNode.java | 70 +
.../ast/{OptionsAstNode.java => FilterKind.java} | 29 +-
.../pinot/pql/parsers/pql2/ast/GroupByAstNode.java | 14 +
.../pinot/pql/parsers/pql2/ast/HavingAstNode.java | 5 +
.../pql/parsers/pql2/ast/InPredicateAstNode.java | 35 +-
.../pinot/pql/parsers/pql2/ast/OptionAstNode.java | 30 +
.../pinot/pql/parsers/pql2/ast/OptionsAstNode.java | 10 +-
.../pinot/pql/parsers/pql2/ast/OrderByAstNode.java | 24 +
.../pql/parsers/pql2/ast/OutputColumnAstNode.java | 27 +
.../parsers/pql2/ast/OutputColumnListAstNode.java | 6 +
.../pql/parsers/pql2/ast/PredicateAstNode.java | 9 +-
.../pql/parsers/pql2/ast/PredicateListAstNode.java | 67 +-
.../pql2/ast/PredicateParenthesisGroupAstNode.java | 6 +
.../pql2/ast/RegexpLikePredicateAstNode.java | 18 +
.../pinot/pql/parsers/pql2/ast/SelectAstNode.java | 31 +
.../parsers/pql2/ast/StarColumnListAstNode.java | 9 +
.../pinot/pql/parsers/pql2/ast/WhereAstNode.java | 7 +
.../apache/pinot/pql/parsers/Pql2CompilerTest.java | 184 +-
.../request/BrokerRequestSerializationTest.java | 143 ++
pinot-common/src/test/resources/pql_queries.list | 814 +++++++++
pinot-common/src/thrift/query.thrift | 70 +
pinot-common/src/thrift/request.thrift | 2 +
.../apache/pinot/controller/ControllerConf.java | 19 +-
.../controller/api/upload/SegmentValidator.java | 3 +-
.../helix/core/assignment/InstancePartitions.java | 99 ++
.../core/assignment/InstancePartitionsUtils.java | 97 ++
...OfflineBalanceNumSegmentAssignmentStrategy.java | 96 ++
...flineReplicaGroupSegmentAssignmentStrategy.java | 200 +++
...ealtimeBalanceNumSegmentAssignmentStrategy.java | 155 ++
...ltimeReplicaGroupSegmentAssignmentStrategy.java | 159 ++
.../segment/SegmentAssignmentStrategy.java | 59 +
.../segment/SegmentAssignmentStrategyFactory.java | 57 +
.../assignment/segment/SegmentAssignmentUtils.java | 276 +++
.../helix/core/minion/PinotTaskManager.java | 2 +-
.../RealtimeSegmentValidationManager.java | 9 +-
.../controller/validation/StorageQuotaChecker.java | 28 +-
...ineBalanceNumSegmentAssignmentStrategyTest.java | 137 ++
...eReplicaGroupSegmentAssignmentStrategyTest.java | 289 ++++
...imeBalanceNumSegmentAssignmentStrategyTest.java | 208 +++
...eReplicaGroupSegmentAssignmentStrategyTest.java | 230 +++
.../segment/SegmentAssignmentTestUtils.java | 28 +-
.../segment/SegmentAssignmentUtilsTest.java | 434 +++++
.../validation/StorageQuotaCheckerTest.java | 19 +-
.../core/query/reduce/InAndNotInComparison.java | 1 +
.../pinot/reduce/HavingClauseComparisonTests.java | 1 -
.../ControllerPeriodicTasksIntegrationTests.java | 71 +-
.../app/pods/application/route.js | 7 +-
.../app/pods/components/alert-details/component.js | 24 +-
.../pods/components/anomaly-summary/component.js | 50 +-
.../pods/components/anomaly-summary/template.hbs | 1 +
.../pods/components/timeseries-chart/component.js | 50 +-
.../app/pods/manage/alerts/index/controller.js | 49 +-
.../app/pods/manage/alerts/index/route.js | 1 -
.../app/pods/manage/alerts/index/template.hbs | 4 +-
.../app/pods/manage/explore/route.js | 21 +-
.../app/pods/manage/explore/template.hbs | 1 +
.../app/pods/screenshot/controller.js | 39 +-
.../app/styles/components/timeseries-chart.scss | 22 +-
thirdeye/thirdeye-frontend/app/utils/rca-utils.js | 6 +-
.../pinot/thirdeye/anomaly/task/TaskDriver.java | 40 +-
.../api/application/ApplicationResource.java | 2 +-
.../api/user/dashboard/UserDashboardResource.java | 12 +-
.../v2/rootcause/AnomalyEventFormatter.java | 3 +-
.../bao/jdbc/MergedAnomalyResultManagerImpl.java | 2 +-
.../thirdeye/datalayer/dto/EvaluationDTO.java | 9 +-
.../datalayer/pojo/DetectionConfigBean.java | 9 +
.../thirdeye/datalayer/pojo/EvaluationBean.java | 6 +-
.../detection/DetectionPipelineTaskRunner.java | 10 +-
.../pinot/thirdeye/detection/DetectionUtils.java | 5 +-
.../thirdeye/detection/ModelMaintenanceFlow.java | 41 +
.../pinot/thirdeye/detection/ModelRetuneFlow.java | 110 ++
.../pinot/thirdeye/detection/alert/AlertUtils.java | 2 +-
.../detection/alert/DetectionAlertScheduler.java | 4 +-
.../detection/alert/DetectionAlertTaskRunner.java | 21 +-
.../alert/scheme/DetectionEmailAlerter.java | 2 +-
.../pinot/thirdeye/detection/annotation/Yaml.java | 39 -
.../annotation/registry/DetectionRegistry.java | 33 +-
.../MapeAveragePercentageChangeModelEvaluator.java | 4 +-
.../onboard/YamlOnboardingTaskRunner.java | 6 -
.../validators/DetectionConfigValidator.java | 20 +-
.../validators/SubscriptionConfigValidator.java | 2 +-
.../detection/wrapper/AnomalyFilterWrapper.java | 10 +-
.../thirdeye/detection/yaml/YamlResource.java | 265 +--
.../yaml/translator/ConfigTranslator.java | 21 +-
...nslator.java => DetectionConfigTranslator.java} | 120 +-
...ator.java => SubscriptionConfigTranslator.java} | 45 +-
.../translator/YamlDetectionConfigTranslator.java | 71 -
.../translator/YamlDetectionTranslatorLoader.java | 45 -
.../thirdeye/detector/holiday-anomaly-report.ftl | 3 +
.../detection/DefaultModelMaintenanceFlowTest.java | 111 ++
.../MapePercentageChangeModelEvaluatorTest.java | 2 +-
.../detection/components/MockModelEvaluator.java | 45 +
.../detection/components/MockTunableDetector.java | 60 +
.../detection/spec/MockModelEvaluatorSpec.java | 38 +
.../thirdeye/detection/spec/MockTunableSpec.java | 26 +
.../thirdeye/detection/yaml/YamlResourceTest.java | 57 +-
...est.java => DetectionConfigTranslatorTest.java} | 25 +-
.../YamlDetectionAlertConfigTranslatorTest.java | 8 +-
.../yaml/detection/detection-config-1.yaml | 22 +
.../yaml/detection/detection-config-2.yaml | 22 +
...multiple-anomalies-email-content-formatter.html | 3 +
148 files changed, 10914 insertions(+), 1573 deletions(-)
create mode 100644 docker/Dockerfile
create mode 100644 docker/README.md
create mode 100755 docker/docker-build-and-push.sh
create mode 100755 docker/docker-build.sh
create mode 100755 docker/docker-push.sh
create mode 100644 licenses-binary/LICENSE-aopalliance.txt
create mode 100644 licenses-binary/LICENSE-asm.txt
create mode 100644 licenses-binary/LICENSE-esotericsoftware.txt
create mode 100644 licenses-binary/LICENSE-jcraft.txt
create mode 100644 licenses-binary/LICENSE-protobuf.txt
create mode 100644 licenses-binary/LICENSE-xmlenc.txt
copy
pinot-common/src/main/java/org/apache/pinot/common/request/{QuerySource.java =>
DataSource.java} (87%)
create mode 100644
pinot-common/src/main/java/org/apache/pinot/common/request/Expression.java
copy
pinot-common/src/main/java/org/apache/pinot/common/request/{FilterOperator.java
=> ExpressionType.java} (70%)
copy
pinot-common/src/main/java/org/apache/pinot/common/{response/ProcessingException.java
=> request/Function.java} (51%)
copy
pinot-common/src/main/java/org/apache/pinot/common/request/{QuerySource.java =>
Identifier.java} (64%)
create mode 100644
pinot-common/src/main/java/org/apache/pinot/common/request/Literal.java
create mode 100644
pinot-common/src/main/java/org/apache/pinot/common/request/PinotQuery.java
copy
pinot-common/src/main/java/org/apache/pinot/{pql/parsers/pql2/ast/OptionsAstNode.java
=> common/utils/InstancePartitionsType.java} (54%)
create mode 100644
pinot-common/src/main/java/org/apache/pinot/pql/parsers/PinotQuery2BrokerRequestConverter.java
copy
pinot-common/src/main/java/org/apache/pinot/pql/parsers/pql2/ast/{OptionsAstNode.java
=> FilterKind.java} (67%)
create mode 100644 pinot-common/src/test/resources/pql_queries.list
create mode 100644 pinot-common/src/thrift/query.thrift
create mode 100644
pinot-controller/src/main/java/org/apache/pinot/controller/helix/core/assignment/InstancePartitions.java
create mode 100644
pinot-controller/src/main/java/org/apache/pinot/controller/helix/core/assignment/InstancePartitionsUtils.java
create mode 100644
pinot-controller/src/main/java/org/apache/pinot/controller/helix/core/assignment/segment/OfflineBalanceNumSegmentAssignmentStrategy.java
create mode 100644
pinot-controller/src/main/java/org/apache/pinot/controller/helix/core/assignment/segment/OfflineReplicaGroupSegmentAssignmentStrategy.java
create mode 100644
pinot-controller/src/main/java/org/apache/pinot/controller/helix/core/assignment/segment/RealtimeBalanceNumSegmentAssignmentStrategy.java
create mode 100644
pinot-controller/src/main/java/org/apache/pinot/controller/helix/core/assignment/segment/RealtimeReplicaGroupSegmentAssignmentStrategy.java
create mode 100644
pinot-controller/src/main/java/org/apache/pinot/controller/helix/core/assignment/segment/SegmentAssignmentStrategy.java
create mode 100644
pinot-controller/src/main/java/org/apache/pinot/controller/helix/core/assignment/segment/SegmentAssignmentStrategyFactory.java
create mode 100644
pinot-controller/src/main/java/org/apache/pinot/controller/helix/core/assignment/segment/SegmentAssignmentUtils.java
create mode 100644
pinot-controller/src/test/java/org/apache/pinot/controller/helix/core/assignment/segment/OfflineBalanceNumSegmentAssignmentStrategyTest.java
create mode 100644
pinot-controller/src/test/java/org/apache/pinot/controller/helix/core/assignment/segment/OfflineReplicaGroupSegmentAssignmentStrategyTest.java
create mode 100644
pinot-controller/src/test/java/org/apache/pinot/controller/helix/core/assignment/segment/RealtimeBalanceNumSegmentAssignmentStrategyTest.java
create mode 100644
pinot-controller/src/test/java/org/apache/pinot/controller/helix/core/assignment/segment/RealtimeReplicaGroupSegmentAssignmentStrategyTest.java
copy
pinot-common/src/main/java/org/apache/pinot/pql/parsers/pql2/ast/OptionsAstNode.java
=>
pinot-controller/src/test/java/org/apache/pinot/controller/helix/core/assignment/segment/SegmentAssignmentTestUtils.java
(62%)
create mode 100644
pinot-controller/src/test/java/org/apache/pinot/controller/helix/core/assignment/segment/SegmentAssignmentUtilsTest.java
create mode 100644
thirdeye/thirdeye-pinot/src/main/java/org/apache/pinot/thirdeye/detection/ModelMaintenanceFlow.java
create mode 100644
thirdeye/thirdeye-pinot/src/main/java/org/apache/pinot/thirdeye/detection/ModelRetuneFlow.java
delete mode 100644
thirdeye/thirdeye-pinot/src/main/java/org/apache/pinot/thirdeye/detection/annotation/Yaml.java
rename
thirdeye/thirdeye-pinot/src/main/java/org/apache/pinot/thirdeye/detection/yaml/translator/{CompositePipelineConfigTranslator.java
=> DetectionConfigTranslator.java} (81%)
rename
thirdeye/thirdeye-pinot/src/main/java/org/apache/pinot/thirdeye/detection/yaml/translator/{YamlDetectionAlertConfigTranslator.java
=> SubscriptionConfigTranslator.java} (80%)
delete mode 100644
thirdeye/thirdeye-pinot/src/main/java/org/apache/pinot/thirdeye/detection/yaml/translator/YamlDetectionConfigTranslator.java
delete mode 100644
thirdeye/thirdeye-pinot/src/main/java/org/apache/pinot/thirdeye/detection/yaml/translator/YamlDetectionTranslatorLoader.java
create mode 100644
thirdeye/thirdeye-pinot/src/test/java/org/apache/pinot/thirdeye/detection/DefaultModelMaintenanceFlowTest.java
create mode 100644
thirdeye/thirdeye-pinot/src/test/java/org/apache/pinot/thirdeye/detection/components/MockModelEvaluator.java
create mode 100644
thirdeye/thirdeye-pinot/src/test/java/org/apache/pinot/thirdeye/detection/components/MockTunableDetector.java
create mode 100644
thirdeye/thirdeye-pinot/src/test/java/org/apache/pinot/thirdeye/detection/spec/MockModelEvaluatorSpec.java
create mode 100644
thirdeye/thirdeye-pinot/src/test/java/org/apache/pinot/thirdeye/detection/spec/MockTunableSpec.java
rename
thirdeye/thirdeye-pinot/src/test/java/org/apache/pinot/thirdeye/detection/yaml/translator/{CompositePipelineConfigTranslatorTest.java
=> DetectionConfigTranslatorTest.java} (77%)
create mode 100644
thirdeye/thirdeye-pinot/src/test/resources/org/apache/pinot/thirdeye/detection/yaml/detection/detection-config-1.yaml
create mode 100644
thirdeye/thirdeye-pinot/src/test/resources/org/apache/pinot/thirdeye/detection/yaml/detection/detection-config-2.yaml
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
