We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent e56d1c4 commit 14fbd26Copy full SHA for 14fbd26
pkg/tsdb/v3iotsdb.go
@@ -353,7 +353,7 @@ func (a *V3ioAdapter) DeletePartitionsData(deleteParams *DeleteParams) error {
353
}
354
355
356
- for i := 0; i <= a.cfg.Workers; i++ {
+ for i := 0; i < a.cfg.Workers; i++ {
357
go deleteObjectWorker(a.container, deleteParams, a.logger,
358
fileToDeleteChan, deleteTerminationChan, onErrorTerminationChannel,
359
aggrMask)
@@ -418,7 +418,6 @@ func (a *V3ioAdapter) DeletePartitionsData(deleteParams *DeleteParams) error {
418
getItemsWG.Wait()
419
select {
420
case err = <-getItemsErrorChan:
421
- fmt.Println("got error", err)
422
// Signal all other goroutines to quite
423
for i := 0; i < goRoutinesNum; i++ {
424
onErrorTerminationChannel <- struct{}{}
0 commit comments