diff --git a/lib/logstorage/storage.go b/lib/logstorage/storage.go
index 4a6f9c0e19..0216be2821 100644
--- a/lib/logstorage/storage.go
+++ b/lib/logstorage/storage.go
@@ -395,7 +395,7 @@ func (s *Storage) MustAddRows(lr *LogRows) {
 	}
 	s.partitionsLock.Unlock()
 
-	if ptwHot != nil {
+	if ptwHot != nil && ptwHot.pt != nil {
 		if ptwHot.canAddAllRows(lr) {
 			ptwHot.pt.mustAddRows(lr)
 			ptwHot.decRef()