diff --git a/datanode/candlesv2/candle_updates.go b/datanode/candlesv2/candle_updates.go
index 348ae8bbb6..41fb0e0d36 100644
--- a/datanode/candlesv2/candle_updates.go
+++ b/datanode/candlesv2/candle_updates.go
@@ -197,7 +197,7 @@ func (s *CandleUpdates) getCandleUpdates(ctx context.Context, lastCandle *entiti
 		}
 
 		for _, candle := range candles {
-			if candle.PeriodStart.After(lastCandle.PeriodStart) {
+			if candle.LastUpdateInPeriod.After(lastCandle.LastUpdateInPeriod) || candle.PeriodStart.After(lastCandle.PeriodStart) {
 				updates = append(updates, candle)
 			}
 		}