This is an automated email from the ASF dual-hosted git repository.
jihao pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-pinot.git
The following commit(s) were added to refs/heads/master by this push:
new 33830cb [TE] suppress the anomaly if current value is NaN (#6428)
33830cb is described below
commit 33830cb3ec44d1206678a73a3c4fc91844fd0334
Author: Jihao Zhang <[email protected]>
AuthorDate: Wed Jan 13 13:07:19 2021 -0800
[TE] suppress the anomaly if current value is NaN (#6428)
---
.../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: [email protected]
For additional commands, e-mail: [email protected]
