We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
2 parents 1a79c2f + c4a21d5 commit 6c79cd1Copy full SHA for 6c79cd1
bq/insert.go
@@ -257,7 +257,6 @@ func (in *BQInserter) Flush() error {
257
// This is heavyweight, and may run forever without a context deadline.
258
ctx, _ := context.WithTimeout(context.Background(), in.timeout)
259
err = in.uploader.Put(ctx, in.rows)
260
- log.Println(err)
261
if err == nil || !strings.Contains(err.Error(), "Quota exceeded:") {
262
break
263
}
cmd/etl_worker/app-ndt.yaml
@@ -37,7 +37,7 @@ network:
37
- 9090/tcp
38
39
env_variables:
40
- MAX_WORKERS: 20
+ MAX_WORKERS: 12
41
BIGQUERY_PROJECT: 'mlab-sandbox'
42
BIGQUERY_DATASET: 'mlab_sandbox'
43
ANNOTATE_IP: 'true'
0 commit comments