Skip to content

Commit be5d511

Browse files
committed
Update scheduler.go
1 parent 8869555 commit be5d511

File tree

1 file changed

+5
-1
lines changed

1 file changed

+5
-1
lines changed

scheduler/scheduler.go

Lines changed: 5 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -316,7 +316,11 @@ func shardTableClients(tableClients []tableClient, shard *shard) []tableClient {
316316
return nil
317317
}
318318
if len(chunks) > total && num == total {
319-
return append(chunks[num-1], chunks[num]...)
319+
chunkReturn := chunks[num-1]
320+
for _, chunk := range chunks[total:] {
321+
chunkReturn = append(chunkReturn, chunk...)
322+
}
323+
return chunkReturn
320324
}
321325
return chunks[num-1]
322326
}

0 commit comments

Comments
 (0)