Apache
/
druid
mirror of https://github.com/apache/druid.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

fix calculation of expected timestamp for query in ITRealtimeIndexTaskTest

This commit is contained in:
Robin 2016-04-01 10:47:17 -05:00
parent 2fc5918e69
commit 10ec53dc1c
1 changed files with 4 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
integration-tests/src/test/java/io/druid/tests/indexer/ITRealtimeIndexTaskTest.java
View File

@ -81,6 +81,7 @@ public class ITRealtimeIndexTaskTest extends AbstractIndexerTest
private final DateTimeFormatter TIMESTAMP_FMT = DateTimeFormat.forPattern("yyyy-MM-dd'T'HH:mm:ss'.000Z'"); private final DateTimeFormatter TIMESTAMP_FMT = DateTimeFormat.forPattern("yyyy-MM-dd'T'HH:mm:ss'.000Z'");
private DateTime dtFirst; // timestamp of 1st event private DateTime dtFirst; // timestamp of 1st event
private DateTime dtLast; // timestamp of last event private DateTime dtLast; // timestamp of last event
private DateTime dtGroupBy; // timestamp for expected response for groupBy query
@Inject @Inject
ServerDiscoveryFactory factory; ServerDiscoveryFactory factory;
@ -130,9 +131,7 @@ public class ITRealtimeIndexTaskTest extends AbstractIndexerTest
.replace("%%TIMESERIES_RESPONSE_TIMESTAMP%%", TIMESTAMP_FMT.print(dtFirst)) .replace("%%TIMESERIES_RESPONSE_TIMESTAMP%%", TIMESTAMP_FMT.print(dtFirst))
.replace("%%POST_AG_REQUEST_START%%", INTERVAL_FMT.print(dtFirst)) .replace("%%POST_AG_REQUEST_START%%", INTERVAL_FMT.print(dtFirst))
.replace("%%POST_AG_REQUEST_END%%", INTERVAL_FMT.print(dtLast.plusMinutes(2))) .replace("%%POST_AG_REQUEST_END%%", INTERVAL_FMT.print(dtLast.plusMinutes(2)))
.replace( .replace("%%POST_AG_RESPONSE_TIMESTAMP%%", TIMESTAMP_FMT.print(dtGroupBy.withSecondOfMinute(0))
"%%POST_AG_RESPONSE_TIMESTAMP%%",
TIMESTAMP_FMT.print(dtLast.minusSeconds(24).withSecondOfMinute(0))
); );
// should hit the queries all on realtime task or some on realtime task // should hit the queries all on realtime task or some on realtime task
@ -215,6 +214,8 @@ public class ITRealtimeIndexTaskTest extends AbstractIndexerTest
while ((line = reader.readLine()) != null) { while ((line = reader.readLine()) != null) {
if (i == 15) { // for the 15th line, use a time before the window if (i == 15) { // for the 15th line, use a time before the window
dt = dt.minusMinutes(10); dt = dt.minusMinutes(10);
} else if (i == 16) { // remember this time to use in the expected response from the groupBy query
dtGroupBy = dt;
} else if (i == 18) { // use a time 6 seconds ago so it will be out of order } else if (i == 18) { // use a time 6 seconds ago so it will be out of order
dt = dt.minusSeconds(6); dt = dt.minusSeconds(6);
} }