Skip to content

Commit 5cf8047

Browse files
authored
traceroute tuning (#724)
* Update app-traceroute.yaml * Update app-batch.yaml * Update app-traceroute.yaml * Update queue.yaml * Update app-batch.yaml * fix * more * Update globals.go * add concurrency * Update globals.go * Update app-batch.yaml * Update app-batch.yaml
1 parent 351687d commit 5cf8047

File tree

2 files changed

+17
-17
lines changed

2 files changed

+17
-17
lines changed

appengine/queue.yaml

Lines changed: 16 additions & 16 deletions
Original file line numberDiff line numberDiff line change
@@ -468,7 +468,7 @@ queue:
468468
rate: 1/s
469469
bucket_size: 10
470470
# max concurrent is limited, because we will share the pipeline with other experiment types
471-
max_concurrent_requests: 5
471+
max_concurrent_requests: 20
472472
retry_parameters:
473473
task_age_limit: 12h
474474
# min and max are same, so that queue rate only diminishes as tasks are drained
@@ -480,7 +480,7 @@ queue:
480480
target: etl-batch-parser
481481
rate: 1/s
482482
bucket_size: 10
483-
max_concurrent_requests: 5
483+
max_concurrent_requests: 20
484484
retry_parameters:
485485
task_age_limit: 12h
486486
min_backoff_seconds: 20
@@ -489,7 +489,7 @@ queue:
489489
target: etl-batch-parser
490490
rate: 1/s
491491
bucket_size: 10
492-
max_concurrent_requests: 5
492+
max_concurrent_requests: 20
493493
retry_parameters:
494494
task_age_limit: 12h
495495
min_backoff_seconds: 20
@@ -498,7 +498,7 @@ queue:
498498
target: etl-batch-parser
499499
rate: 1/s
500500
bucket_size: 10
501-
max_concurrent_requests: 5
501+
max_concurrent_requests: 20
502502
retry_parameters:
503503
task_age_limit: 12h
504504
min_backoff_seconds: 20
@@ -507,7 +507,7 @@ queue:
507507
target: etl-batch-parser
508508
rate: 1/s
509509
bucket_size: 10
510-
max_concurrent_requests: 5
510+
max_concurrent_requests: 20
511511
retry_parameters:
512512
task_age_limit: 12h
513513
min_backoff_seconds: 20
@@ -516,7 +516,7 @@ queue:
516516
target: etl-batch-parser
517517
rate: 1/s
518518
bucket_size: 10
519-
max_concurrent_requests: 5
519+
max_concurrent_requests: 20
520520
retry_parameters:
521521
task_age_limit: 12h
522522
min_backoff_seconds: 20
@@ -525,7 +525,7 @@ queue:
525525
target: etl-batch-parser
526526
rate: 1/s
527527
bucket_size: 10
528-
max_concurrent_requests: 5
528+
max_concurrent_requests: 20
529529
retry_parameters:
530530
task_age_limit: 12h
531531
min_backoff_seconds: 20
@@ -534,7 +534,7 @@ queue:
534534
target: etl-batch-parser
535535
rate: 1/s
536536
bucket_size: 10
537-
max_concurrent_requests: 5
537+
max_concurrent_requests: 20
538538
retry_parameters:
539539
task_age_limit: 12h
540540
min_backoff_seconds: 20
@@ -543,7 +543,7 @@ queue:
543543
target: etl-batch-parser
544544
rate: 1/s
545545
bucket_size: 10
546-
max_concurrent_requests: 5
546+
max_concurrent_requests: 20
547547
retry_parameters:
548548
task_age_limit: 12h
549549
min_backoff_seconds: 20
@@ -552,7 +552,7 @@ queue:
552552
target: etl-batch-parser
553553
rate: 1/s
554554
bucket_size: 10
555-
max_concurrent_requests: 5
555+
max_concurrent_requests: 20
556556
retry_parameters:
557557
task_age_limit: 12h
558558
min_backoff_seconds: 20
@@ -561,7 +561,7 @@ queue:
561561
target: etl-batch-parser
562562
rate: 1/s
563563
bucket_size: 10
564-
max_concurrent_requests: 5
564+
max_concurrent_requests: 20
565565
retry_parameters:
566566
task_age_limit: 12h
567567
min_backoff_seconds: 20
@@ -570,7 +570,7 @@ queue:
570570
target: etl-batch-parser
571571
rate: 1/s
572572
bucket_size: 10
573-
max_concurrent_requests: 5
573+
max_concurrent_requests: 20
574574
retry_parameters:
575575
task_age_limit: 12h
576576
min_backoff_seconds: 20
@@ -579,7 +579,7 @@ queue:
579579
target: etl-batch-parser
580580
rate: 1/s
581581
bucket_size: 10
582-
max_concurrent_requests: 5
582+
max_concurrent_requests: 20
583583
retry_parameters:
584584
task_age_limit: 12h
585585
min_backoff_seconds: 20
@@ -588,7 +588,7 @@ queue:
588588
target: etl-batch-parser
589589
rate: 1/s
590590
bucket_size: 10
591-
max_concurrent_requests: 5
591+
max_concurrent_requests: 20
592592
retry_parameters:
593593
task_age_limit: 12h
594594
min_backoff_seconds: 20
@@ -597,7 +597,7 @@ queue:
597597
target: etl-batch-parser
598598
rate: 1/s
599599
bucket_size: 10
600-
max_concurrent_requests: 5
600+
max_concurrent_requests: 20
601601
retry_parameters:
602602
task_age_limit: 12h
603603
min_backoff_seconds: 20
@@ -606,7 +606,7 @@ queue:
606606
target: etl-batch-parser
607607
rate: 1/s
608608
bucket_size: 10
609-
max_concurrent_requests: 5
609+
max_concurrent_requests: 20
610610
retry_parameters:
611611
task_age_limit: 12h
612612
min_backoff_seconds: 20

etl/globals.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -255,7 +255,7 @@ var (
255255
NDT_OMIT_DELTAS: 50,
256256
TCPINFO: 10,
257257
SS: 500, // Average json size is 2.5K
258-
PT: 5,
258+
PT: 100,
259259
SW: 100,
260260
NDT5: 50,
261261
NDT7: 50,

0 commit comments

Comments
 (0)