@@ -869,7 +869,9 @@ func (e *IndexLookUpExecutor) buildTableReader(ctx context.Context, task *lookup
869
869
tableReaderExec .buildVirtualColumnInfo ()
870
870
tableReader , err := e .dataReaderBuilder .buildTableReaderFromHandles (ctx , tableReaderExec , task .handles , true )
871
871
if err != nil {
872
- logutil .Logger (ctx ).Error ("build table reader from handles failed" , zap .Error (err ))
872
+ if ctx .Err () != context .Canceled {
873
+ logutil .Logger (ctx ).Error ("build table reader from handles failed" , zap .Error (err ))
874
+ }
873
875
return nil , err
874
876
}
875
877
return tableReader , nil
@@ -1531,7 +1533,9 @@ func (w *tableWorker) executeTask(ctx context.Context, task *lookupTableTask) er
1531
1533
tableReader , err := w .idxLookup .buildTableReader (ctx , task )
1532
1534
task .buildDoneTime = time .Now ()
1533
1535
if err != nil {
1534
- logutil .Logger (ctx ).Error ("build table reader failed" , zap .Error (err ))
1536
+ if ctx .Err () != context .Canceled {
1537
+ logutil .Logger (ctx ).Error ("build table reader failed" , zap .Error (err ))
1538
+ }
1535
1539
return err
1536
1540
}
1537
1541
defer func () { terror .Log (exec .Close (tableReader )) }()
@@ -1562,7 +1566,9 @@ func (w *tableWorker) executeTask(ctx context.Context, task *lookupTableTask) er
1562
1566
chk := exec .TryNewCacheChunk (tableReader )
1563
1567
err = exec .Next (ctx , tableReader , chk )
1564
1568
if err != nil {
1565
- logutil .Logger (ctx ).Error ("table reader fetch next chunk failed" , zap .Error (err ))
1569
+ if ctx .Err () != context .Canceled {
1570
+ logutil .Logger (ctx ).Error ("table reader fetch next chunk failed" , zap .Error (err ))
1571
+ }
1566
1572
return err
1567
1573
}
1568
1574
if chk .NumRows () == 0 {
0 commit comments