Skip to content

Commit

Permalink
fix conflicts
Browse files Browse the repository at this point in the history
Signed-off-by: guo-shaoge <shaoge1994@163.com>
  • Loading branch information
guo-shaoge committed Feb 6, 2023
1 parent 6bdd527 commit 6574662
Showing 1 changed file with 0 additions and 11 deletions.
11 changes: 0 additions & 11 deletions executor/index_merge_reader.go
Original file line number Diff line number Diff line change
Expand Up @@ -1230,19 +1230,12 @@ func (w *indexMergeTableScanWorker) pickAndExecTask(ctx context.Context, task **
atomic.AddInt64(&w.stats.FetchRow, int64(time.Since(execStart)))
atomic.AddInt64(&w.stats.TableTaskNum, 1)
}
<<<<<<< HEAD
=======
failpoint.Inject("testIndexMergePickAndExecTaskPanic", nil)
>>>>>>> df204de9bb6d156047a1541f815c71869113ad94
(*task).doneCh <- err
}
}

<<<<<<< HEAD
func (w *indexMergeTableScanWorker) handleTableScanWorkerPanic(ctx context.Context, finished <-chan struct{}, task **indexMergeTableTask, worker string) func(r interface{}) {
=======
func (w *indexMergeTableScanWorker) handlePickAndExecTaskPanic(ctx context.Context, task **indexMergeTableTask) func(r interface{}) {
>>>>>>> df204de9bb6d156047a1541f815c71869113ad94
return func(r interface{}) {
if r == nil {
return
Expand All @@ -1251,7 +1244,6 @@ func (w *indexMergeTableScanWorker) handlePickAndExecTaskPanic(ctx context.Conte
err4Panic := errors.Errorf("%s: %v", worker, r)
logutil.Logger(ctx).Error(err4Panic.Error())
if *task != nil {
<<<<<<< HEAD
select {
case <-ctx.Done():
return
Expand All @@ -1260,9 +1252,6 @@ func (w *indexMergeTableScanWorker) handlePickAndExecTaskPanic(ctx context.Conte
case (*task).doneCh <- err4Panic:
return
}
=======
(*task).doneCh <- err4Panic
>>>>>>> df204de9bb6d156047a1541f815c71869113ad94
}
}
}
Expand Down

0 comments on commit 6574662

Please sign in to comment.