You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pinot.apache.org by ji...@apache.org on 2021/01/08 23:12:48 UTC
[incubator-pinot] branch filter-nan-anomalies created (now efac5b4)
This is an automated email from the ASF dual-hosted git repository.
jihao pushed a change to branch filter-nan-anomalies
in repository https://gitbox.apache.org/repos/asf/incubator-pinot.git.
at efac5b4 [TE] suppress the anomaly if current value is NaN
This branch includes the following new commits:
new efac5b4 [TE] suppress the anomaly if current value is NaN
The 1 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.
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@pinot.apache.org
For additional commands, e-mail: commits-help@pinot.apache.org
[incubator-pinot] 01/01: [TE] suppress the anomaly if current value
is NaN
Posted by ji...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
jihao pushed a commit to branch filter-nan-anomalies
in repository https://gitbox.apache.org/repos/asf/incubator-pinot.git
commit efac5b4a5f260bf63ecc85a04230d65f26c451d1
Author: Jihao Zhang <ji...@linkedin.com>
AuthorDate: Fri Jan 8 14:37:38 2021 -0800
[TE] suppress the anomaly if current value is NaN
---
.../apache/pinot/thirdeye/detection/DetectionPipelineTaskRunner.java | 4 +++-
1 file changed, 3 insertions(+), 1 deletion(-)
diff --git a/thirdeye/thirdeye-pinot/src/main/java/org/apache/pinot/thirdeye/detection/DetectionPipelineTaskRunner.java b/thirdeye/thirdeye-pinot/src/main/java/org/apache/pinot/thirdeye/detection/DetectionPipelineTaskRunner.java
index 90b4d64..8f491c7 100644
--- a/thirdeye/thirdeye-pinot/src/main/java/org/apache/pinot/thirdeye/detection/DetectionPipelineTaskRunner.java
+++ b/thirdeye/thirdeye-pinot/src/main/java/org/apache/pinot/thirdeye/detection/DetectionPipelineTaskRunner.java
@@ -157,7 +157,9 @@ public class DetectionPipelineTaskRunner implements TaskRunner {
config.setLastTimestamp(result.getLastTimestamp());
for (MergedAnomalyResultDTO mergedAnomalyResultDTO : result.getAnomalies()) {
- this.anomalyDAO.save(mergedAnomalyResultDTO);
+ if (!Double.isNaN(mergedAnomalyResultDTO.getAvgCurrentVal())){
+ this.anomalyDAO.save(mergedAnomalyResultDTO);
+ }
if (mergedAnomalyResultDTO.getId() == null) {
LOG.warn("Could not store anomaly:\n{}", mergedAnomalyResultDTO);
}
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@pinot.apache.org
For additional commands, e-mail: commits-help@pinot.apache.org