fix: show tag values skip sid not found in index (openGemini#583)

Signed-off-by: xiangyu5632 <[email protected]>

Author: xiangyu5632

engine/immutable/sequence_iterator.go

@@ -148,14 +148,12 @@ func (itr *sequenceIterator) iterateFile(f TSSPFile) error {
 		offsets = append(offsets, uint32(len(buf)))
 		for k := 0; k < len(offsets)-1; k++ {
 			err = itr.handler.NextChunkMeta(buf[offsets[k]:offsets[k+1]])
-			if err != nil {
-				return err
-			}
-
-			// sid not found in index, skip
-			if errno.Equal(err, errno.ErrSearchSeriesKey) {
+			if err != nil && errno.Equal(err, errno.ErrSearchSeriesKey) {
+				// sid not found in index, skip
 				itr.logger.Warn("sequenceIterator.iterateFile NextChunkMeta search sid failed", zap.Error(err))
 				continue
+			} else if err != nil {
+				return err
 			}
 
 			// reach the limit

engine/immutable/sequence_iterator_test.go

@@ -88,6 +88,9 @@ func TestSequenceIterator_Run(t *testing.T) {
 		ReadChunkMetasFn: func(f TSSPFile, idx int) ([]byte, []uint32, error) { return make([]byte, 10), make([]uint32, 10), nil },
 	}
 
+	errSearchSeriesKey := errno.NewError(errno.ErrSearchSeriesKey)
+	mockErr := errors.New("mock error")
+
 	for _, testcase := range []struct {
 		Name    string
 		Handler SequenceIteratorHandler
@@ -115,14 +118,38 @@ func TestSequenceIterator_Run(t *testing.T) {
 			},
 			Err: io.EOF,
 		},
+		{
+			Name: "ErrSearchSeriesKey",
+			Handler: &MockSequenceIteratorHandler{
+				BeginFn:         func() {},
+				FinishFn:        func() {},
+				NextFileFn:      func(file TSSPFile) {},
+				NextChunkMetaFn: func(bytes []byte) error { return errSearchSeriesKey },
+				LimitedFn:       func() bool { return false },
+			},
+			Err: nil,
+		},
+		{
+			Name: "Unknown Error",
+			Handler: &MockSequenceIteratorHandler{
+				BeginFn:         func() {},
+				FinishFn:        func() {},
+				NextFileFn:      func(file TSSPFile) {},
+				NextChunkMetaFn: func(bytes []byte) error { return mockErr },
+				LimitedFn:       func() bool { return false },
+			},
+			Err: mockErr,
+		},
 	} {
-		iterator := NewSequenceIterator(testcase.Handler, logger.NewLogger(errno.ModuleUnknown).SetZapLogger(zap.NewNop()))
-		iterator.SetChunkMetasReader(metaReader)
-		iterator.AddFiles(tsspFiles)
-		err := iterator.Run()
-		if !errors.Is(err, testcase.Err) {
-			t.Fatalf("SequenceIterator.Run failed, actual %v, expected: %v", err, testcase.Err)
-		}
+		t.Run(testcase.Name, func(t *testing.T) {
+			iterator := NewSequenceIterator(testcase.Handler, logger.NewLogger(errno.ModuleUnknown).SetZapLogger(zap.NewNop()))
+			iterator.SetChunkMetasReader(metaReader)
+			iterator.AddFiles(tsspFiles)
+			err := iterator.Run()
+			if !errors.Is(err, testcase.Err) {
+				t.Fatalf("SequenceIterator.Run failed, actual %v, expected: %v", err, testcase.Err)
+			}
+		})
 	}
 
 }