mirror of https://github.com/apache/druid.git
better comment
This commit is contained in:
parent
c48c4ac0f6
commit
87b83e7bdb
|
@ -613,7 +613,7 @@ public class RealtimePlumber implements Plumber
|
||||||
minTimestampAsDate = segmentGranularity.truncate(rejectionPolicy.getCurrMaxTime().minus(windowMillis));
|
minTimestampAsDate = segmentGranularity.truncate(rejectionPolicy.getCurrMaxTime().minus(windowMillis));
|
||||||
}
|
}
|
||||||
catch (ArithmeticException e) {
|
catch (ArithmeticException e) {
|
||||||
//caused when rejectionPolicy.currMaxTime minus windowMillis exceeds the capacity of long
|
//thrown when rejectionPolicy.currMaxTime minus windowMillis exceeds the capacity of long
|
||||||
minTimestampAsDate = segmentGranularity.truncate(rejectionPolicy.getCurrMaxTime());
|
minTimestampAsDate = segmentGranularity.truncate(rejectionPolicy.getCurrMaxTime());
|
||||||
}
|
}
|
||||||
long minTimestamp = minTimestampAsDate.getMillis();
|
long minTimestamp = minTimestampAsDate.getMillis();
|
||||||
|
|
Loading…
Reference in New Issue