This is an automated email from the ASF dual-hosted git repository.
xhsun 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 15ff8d8 [TE] rootcause - Round end time after adjusting with the
maxDateTime (#3581)
15ff8d8 is described below
commit 15ff8d8bf24d40edda3a82d3091586ccdb1e591c
Author: Xiaohui Sun <[email protected]>
AuthorDate: Mon Dec 3 21:49:08 2018 -0800
[TE] rootcause - Round end time after adjusting with the maxDateTime (#3581)
* [TE] rootcause - Round end time again to fix last zero data point in
alert page
* [TE] rootcause - move round end time after adjusting with max data time
---
.../linkedin/thirdeye/dashboard/resources/v2/TimeSeriesResource.java | 5 +++--
1 file changed, 3 insertions(+), 2 deletions(-)
diff --git
a/thirdeye/thirdeye-pinot/src/main/java/com/linkedin/thirdeye/dashboard/resources/v2/TimeSeriesResource.java
b/thirdeye/thirdeye-pinot/src/main/java/com/linkedin/thirdeye/dashboard/resources/v2/TimeSeriesResource.java
index d6a80a5..c92e440 100644
---
a/thirdeye/thirdeye-pinot/src/main/java/com/linkedin/thirdeye/dashboard/resources/v2/TimeSeriesResource.java
+++
b/thirdeye/thirdeye-pinot/src/main/java/com/linkedin/thirdeye/dashboard/resources/v2/TimeSeriesResource.java
@@ -98,14 +98,15 @@ public class TimeSeriesResource {
DatasetConfigDTO datasetConfig =
DAO_REGISTRY.getDatasetConfigDAO().findByDataset(dataset);
long maxDataTime = datasetMaxDataTimeCache.get(dataset);
- currentEnd = roundEndTimeByGranularity(currentEnd, datasetConfig);
- baselineEnd = roundEndTimeByGranularity(baselineEnd, datasetConfig);
if (currentEnd > maxDataTime) {
long delta = currentEnd - maxDataTime;
currentEnd = currentEnd - delta;
baselineEnd = baselineStart + (currentEnd - currentStart);
}
+ currentEnd = roundEndTimeByGranularity(currentEnd, datasetConfig);
+ baselineEnd = roundEndTimeByGranularity(baselineEnd, datasetConfig);
+
long analysisDuration = currentEnd - currentStart;
if (baselineEnd - baselineStart != analysisDuration) {
baselineEnd = baselineStart + analysisDuration;
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
