Remove default taskListActivitiesPerSecond limit (#578)

Author: meiliang86

.buildkite/pipeline.yml

@@ -9,7 +9,7 @@ steps:
       queue: "workers"
       docker: "*"
     command: "./gradlew --no-daemon test"
-    timeout_in_minutes: 30
+    timeout_in_minutes: 15
     retry:
       automatic:
         - exit_status: "*"
@@ -24,7 +24,7 @@ steps:
       queue: "workers"
       docker: "*"
     command: "./gradlew --no-daemon test"
-    timeout_in_minutes: 30
+    timeout_in_minutes: 15
     retry:
       automatic:
         - exit_status: "*"
@@ -39,7 +39,7 @@ steps:
       queue: "workers"
       docker: "*"
     command: "./gradlew --no-daemon test"
-    timeout_in_minutes: 30
+    timeout_in_minutes: 15
     retry:
       automatic:
         - exit_status: "*"

docker/buildkite/docker-compose.yaml

@@ -3,15 +3,21 @@ version: '3.5'
 services:
   cassandra:
     image: cassandra:3.11
-    logging:
-      driver: none
+    deploy:
+      resources:
+        limits:
+          cpus: '4'
+          memory: 12000M
     ports:
       - "9042:9042"
 
   statsd:
     image: hopsoft/graphite-statsd
-    logging:
-      driver: none
+    deploy:
+      resources:
+        limits:
+          cpus: '0.50'
+          memory: 1024M
     ports:
       - "8080:80"
       - "2003:2003"
@@ -20,8 +26,11 @@ services:
 
   cadence:
     image: ubercadence/server:latestRelease-auto-setup
-    logging:
-      driver: none
+    deploy:
+      resources:
+        limits:
+          cpus: '2'
+          memory: 8192M
     ports:
       - "7933:7933"
       - "7934:7934"
@@ -39,6 +48,11 @@ services:
       context: ../../
       dockerfile: ./docker/buildkite/Dockerfile
     command: "./gradlew --no-daemon test"
+    deploy:
+      resources:
+        limits:
+          cpus: '2'
+          memory: 8192M
     environment:
       - "USER=unittest"
       - "CADENCE_SEEDS=cadence"
@@ -54,6 +68,11 @@ services:
       context: ../../
       dockerfile: ./docker/buildkite/Dockerfile
     command: "./gradlew --no-daemon test"
+    deploy:
+      resources:
+        limits:
+          cpus: '2'
+          memory: 8192M
     environment:
       - "USER=unittest"
       - "CADENCE_SEEDS=cadence"

src/main/java/com/uber/cadence/internal/replay/ReplayDecider.java

@@ -685,8 +685,13 @@ public HistoryEvent next() {
           if (!current.hasNext()) {
             log.error(
                 "GetWorkflowExecutionHistory returns an empty history, maybe a bug in server, workflowID:"
-                        + request.execution.workflowId+", runID:"+request.execution.runId+", domain:"+request.domain
-                        +" token:" + Arrays.toString(request.getNextPageToken()));
+                    + request.execution.workflowId
+                    + ", runID:"
+                    + request.execution.runId
+                    + ", domain:"
+                    + request.domain
+                    + " token:"
+                    + Arrays.toString(request.getNextPageToken()));
             throw new Error(
                 "GetWorkflowExecutionHistory return empty history, maybe a bug in server");
           }

src/main/java/com/uber/cadence/worker/WorkerOptions.java

@@ -47,7 +47,7 @@ public static final class Builder {
     private int maxConcurrentActivityExecutionSize = 100;
     private int maxConcurrentWorkflowExecutionSize = 50;
     private int maxConcurrentLocalActivityExecutionSize = 100;
-    private double taskListActivitiesPerSecond = 100000;
+    private double taskListActivitiesPerSecond;
     private PollerOptions activityPollerOptions;
     private PollerOptions workflowPollerOptions;
     private Function<WorkflowInterceptor, WorkflowInterceptor> interceptorFactory = (n) -> n;
@@ -128,7 +128,7 @@ public Builder setInterceptorFactory(
      * Notice that the number is represented in double, so that you can set it to less than 1 if
      * needed. For example, set the number to 0.1 means you want your activity to be executed once
      * every 10 seconds. This can be used to protect down stream services from flooding. The zero
-     * value of this uses the default value. Default: 100k
+     * value means there's no limit.
      */
     public Builder setTaskListActivitiesPerSecond(double taskListActivitiesPerSecond) {
       this.taskListActivitiesPerSecond = taskListActivitiesPerSecond;