Tune concurrency options

uwburn · Mar 19, 2019 · 0908ea6 · 0908ea6
1 parent ca5bfa5
commit 0908ea6
Show file tree

Hide file tree

Showing 3 changed files with 3 additions and 3 deletions.
diff --git a/worker/base/BaseSink.js b/worker/base/BaseSink.js
@@ -8,7 +8,7 @@ module.exports = class BaseSink {
     this.databaseOpts = databaseOpts;
 
     this.queryConcurrency = parseInt(process.env.QUERY_CONCURRENCY) || queryConcurrency || 16;
-    this.recordConcurrency = parseInt(process.env.RECORD_CONCURRENCY) || recordConcurrency || 16;
+    this.recordConcurrency = parseInt(process.env.RECORD_CONCURRENCY) || recordConcurrency || 4;
 
     this.latencyByType = {
       INTERVAL_RANGE: 0,

diff --git a/worker/couchbase/CouchbaseMachineSink.js b/worker/couchbase/CouchbaseMachineSink.js
@@ -35,7 +35,7 @@ function subtractValues(o1, o2) {
 module.exports = class CouchbaseMachineSink extends BaseSink {
 
   constructor(databaseOpts) {
-    super(databaseOpts, 16, 16);
+    super(databaseOpts, 16, 4);
   }
 
   async init() {

diff --git a/worker/mongo/MongoMachineSink.js b/worker/mongo/MongoMachineSink.js
@@ -66,7 +66,7 @@ function chooseBucketTime(interval) {
 module.exports = class MongoMachineSink extends BaseSink {
 
   constructor(databaseOpts) {
-    super(databaseOpts, 64, 64);
+    super(databaseOpts, 16, 4);
 
     this.timeComplexCollections = { };
     this.intervalCollections = { };