diff --git a/contrib/ondiskagg/aggtrigger/aggtrigger.go b/contrib/ondiskagg/aggtrigger/aggtrigger.go index dc4a5b1ba..5f25f9cf7 100644 --- a/contrib/ondiskagg/aggtrigger/aggtrigger.go +++ b/contrib/ondiskagg/aggtrigger/aggtrigger.go @@ -226,6 +226,10 @@ func (s *OnDiskAggTrigger) writeAggregates( return err } + if len(slc.GetEpoch()) == 0 { + return nil + } + // decide whether to apply market-hour filter applyingFilter := false if s.filter == "nasdaq" && window.Duration() >= utils.Day {