diff --git a/java/integTest/src/test/java/glide/cluster/ClusterClientTests.java b/java/integTest/src/test/java/glide/cluster/ClusterClientTests.java
index 007f543b1e..fe8ae0e061 100644
--- a/java/integTest/src/test/java/glide/cluster/ClusterClientTests.java
+++ b/java/integTest/src/test/java/glide/cluster/ClusterClientTests.java
@@ -111,7 +111,7 @@ public void send_and_receive_non_ascii_unicode() {
     @ParameterizedTest
     @ValueSource(ints = {100, 2 ^ 16})
     public void client_can_handle_concurrent_workload(int valueSize) {
-        ExecutorService executorService = Executors.newFixedThreadPool(8);
+        ExecutorService executorService = Executors.newCachedThreadPool();
         RedisClusterClient client =
                 RedisClusterClient.CreateClient(commonClusterClientConfig().build()).get();
         CompletableFuture[] futures = new CompletableFuture[100];
diff --git a/java/integTest/src/test/java/glide/standalone/StandaloneClientTests.java b/java/integTest/src/test/java/glide/standalone/StandaloneClientTests.java
index 3877067556..e1927059eb 100644
--- a/java/integTest/src/test/java/glide/standalone/StandaloneClientTests.java
+++ b/java/integTest/src/test/java/glide/standalone/StandaloneClientTests.java
@@ -96,7 +96,7 @@ public void send_and_receive_non_ascii_unicode() {
     @ParameterizedTest
     @ValueSource(ints = {100, 2 ^ 16})
     public void client_can_handle_concurrent_workload(int valueSize) {
-        ExecutorService executorService = Executors.newFixedThreadPool(8);
+        ExecutorService executorService = Executors.newCachedThreadPool();
         RedisClient client = RedisClient.CreateClient(commonClientConfig().build()).get();
         CompletableFuture[] futures = new CompletableFuture[100];