Fix runner

wzshiming · wzshiming · commit bfa2b6c68263 · 2025-11-21T09:52:37.000+08:00
diff --git a/pkg/runner/chunk_runner.go b/pkg/runner/chunk_runner.go
@@ -147,6 +147,14 @@ func (r *ChunkRunner) unmarkRecord(name string) {
 	delete(r.record, name)
 }
 
+func (r *ChunkRunner) clearRecord() {
+	r.recordMut.Lock()
+	defer r.recordMut.Unlock()
+	if len(r.record) != 0 {
+		r.record = map[string]struct{}{}
+	}
+}
+
 func (r *ChunkRunner) enqueueChunk() {
 	select {
 	case r.signal <- struct{}{}:
@@ -950,6 +958,7 @@ func (r *ChunkRunner) handlePending(ctx context.Context, chunks []*v1alpha1.Chun
 	}
 
 	if size == 0 {
+		r.clearRecord()
 		return ErrNoPendingChunk
 	}
 

Original file line number	Diff line number	Diff line change
`@@ -147,6 +147,14 @@ func (r *ChunkRunner) unmarkRecord(name string) {`
`147`	`147`	`delete(r.record, name)`
`148`	`148`	`}`
`149`	`149`
	`150`	`+func (r *ChunkRunner) clearRecord() {`
	`151`	`+ r.recordMut.Lock()`
	`152`	`+ defer r.recordMut.Unlock()`
	`153`	`+ if len(r.record) != 0 {`
	`154`	`+ r.record = map[string]struct{}{}`
	`155`	`+ }`
	`156`	`+}`
	`157`	`+`
`150`	`158`	`func (r *ChunkRunner) enqueueChunk() {`
`151`	`159`	`select {`
`152`	`160`	`case r.signal <- struct{}{}:`
`@@ -950,6 +958,7 @@ func (r ChunkRunner) handlePending(ctx context.Context, chunks []v1alpha1.Chun`
`950`	`958`	`}`
`951`	`959`
`952`	`960`	`if size == 0 {`
	`961`	`+ r.clearRecord()`
`953`	`962`	`return ErrNoPendingChunk`
`954`	`963`	`}`
`955`	`964`