diff --git a/temporal-sdk/src/test/java/io/temporal/workflow/queryTests/LocalActivityAndQueryTest.java b/temporal-sdk/src/test/java/io/temporal/workflow/queryTests/LocalActivityAndQueryTest.java
index 86a706c2ad..f5f3ec3fb7 100644
--- a/temporal-sdk/src/test/java/io/temporal/workflow/queryTests/LocalActivityAndQueryTest.java
+++ b/temporal-sdk/src/test/java/io/temporal/workflow/queryTests/LocalActivityAndQueryTest.java
@@ -76,7 +76,7 @@ public void testLocalActivityAndQuery() throws ExecutionException, InterruptedEx
     // as all these activities are executed in a single workflow task.
     // Query should only see the result after executing all local activities.
     List<ForkJoinTask<String>> tasks = new ArrayList<>();
-    int threads = 30;
+    int threads = 10;
     for (int i = 0; i < threads; i++) {
       ForkJoinTask<String> task = ForkJoinPool.commonPool().submit(workflowStub::query);
       tasks.add(task);