Skip to content

Commit 5e41893

Browse files
committed
Fix: Do not stop Stream due to KeyToList error.
1 parent b80c792 commit 5e41893

File tree

1 file changed

+2
-1
lines changed

1 file changed

+2
-1
lines changed

Diff for: stream.go

+2-1
Original file line numberDiff line numberDiff line change
@@ -236,7 +236,8 @@ func (st *Stream) produceKVs(ctx context.Context, threadId int) error {
236236
itr.Alloc.Reset()
237237
list, err := st.KeyToList(item.KeyCopy(nil), itr)
238238
if err != nil {
239-
return err
239+
st.db.opt.Warningf("While reading key: %x, got error: %v", item.Key(), err)
240+
continue
240241
}
241242
if list == nil || len(list.Kv) == 0 {
242243
continue

0 commit comments

Comments
 (0)