Skip to content

Commit 0f1394d

Browse files
committed
Break the rand scaling
1 parent f2a786e commit 0f1394d

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

bq/insert.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -263,7 +263,7 @@ func (in *BQInserter) Flush() error {
263263
}
264264
metrics.WarningCount.WithLabelValues(in.TableBase(), "", "Quota Exceeded").Inc()
265265
// Use some randomness to reduce risk of synchronization across tasks.
266-
time.Sleep(time.Duration((0.5 + rand.Float64()) * in.params.RetryDelay.Seconds()))
266+
time.Sleep(time.Seconds((0.5 + rand.Float64()) * in.params.RetryDelay.Seconds()))
267267
}
268268

269269
// If there is still an error, then handle it.

0 commit comments

Comments
 (0)