File tree Expand file tree Collapse file tree 1 file changed +2
-1
lines changed
src/main/java/com/arpnetworking/clusteraggregator/aggregation Expand file tree Collapse file tree 1 file changed +2
-1
lines changed Original file line number Diff line number Diff line change @@ -237,10 +237,11 @@ private void processAggregationMessage(final Messages.StatisticSetRecord data) {
237
237
final ZonedDateTime periodStart = ZonedDateTime .parse (data .getPeriodStart ());
238
238
if (periodStart .plus (_period ).plus (_aggregatorTimeout ).isBefore (ZonedDateTime .now ())) {
239
239
// We got a bit of data that is too old for us to aggregate.
240
+ @ Nullable final StreamingAggregationBucket firstBucket = _aggBuckets .getFirst ();
240
241
WORK_TOO_OLD_LOGGER .warn ()
241
242
.setMessage ("Received a work item that is too old to aggregate" )
242
243
.addData ("start" , periodStart )
243
- .addData ("firstStart" , _aggBuckets . getFirst () .getPeriodStart ())
244
+ .addData ("firstStart" , firstBucket == null ? null : firstBucket .getPeriodStart ())
244
245
.addData ("metric" , data .getMetric ())
245
246
.addData ("dimensions" , data .getDimensionsMap ())
246
247
.addContext ("actor" , self ())
You can’t perform that action at this time.
0 commit comments