@@ -890,7 +890,9 @@ func (e *IndexLookUpExecutor) buildTableReader(ctx context.Context, task *lookup
890
890
tableReaderExec .buildVirtualColumnInfo ()
891
891
tableReader , err := e .dataReaderBuilder .buildTableReaderFromHandles (ctx , tableReaderExec , task .handles , true )
892
892
if err != nil {
893
- logutil .Logger (ctx ).Error ("build table reader from handles failed" , zap .Error (err ))
893
+ if ctx .Err () != context .Canceled {
894
+ logutil .Logger (ctx ).Error ("build table reader from handles failed" , zap .Error (err ))
895
+ }
894
896
return nil , err
895
897
}
896
898
return tableReader , nil
@@ -1533,7 +1535,9 @@ func (w *tableWorker) executeTask(ctx context.Context, task *lookupTableTask) er
1533
1535
tableReader , err := w .idxLookup .buildTableReader (ctx , task )
1534
1536
task .buildDoneTime = time .Now ()
1535
1537
if err != nil {
1536
- logutil .Logger (ctx ).Error ("build table reader failed" , zap .Error (err ))
1538
+ if ctx .Err () != context .Canceled {
1539
+ logutil .Logger (ctx ).Error ("build table reader failed" , zap .Error (err ))
1540
+ }
1537
1541
return err
1538
1542
}
1539
1543
defer func () { terror .Log (exec .Close (tableReader )) }()
@@ -1564,7 +1568,9 @@ func (w *tableWorker) executeTask(ctx context.Context, task *lookupTableTask) er
1564
1568
chk := exec .TryNewCacheChunk (tableReader )
1565
1569
err = exec .Next (ctx , tableReader , chk )
1566
1570
if err != nil {
1567
- logutil .Logger (ctx ).Error ("table reader fetch next chunk failed" , zap .Error (err ))
1571
+ if ctx .Err () != context .Canceled {
1572
+ logutil .Logger (ctx ).Error ("table reader fetch next chunk failed" , zap .Error (err ))
1573
+ }
1568
1574
return err
1569
1575
}
1570
1576
if chk .NumRows () == 0 {
0 commit comments