Changes

Tim-Brooks · Aug 13, 2024 · 87f4297 · 87f4297
1 parent 7be3787
commit 87f4297
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 4 deletions.
diff --git a/server/src/internalClusterTest/java/org/elasticsearch/action/bulk/IncrementalBulkIT.java b/server/src/internalClusterTest/java/org/elasticsearch/action/bulk/IncrementalBulkIT.java
@@ -98,7 +98,6 @@ public void run() {
 
             executorService.execute(r);
 
-
             BulkResponse bulkResponse = future.actionGet();
             assertNoFailures(bulkResponse);
 
@@ -155,7 +154,6 @@ public void run() {
 
             executorService.execute(r);
 
-
             BulkResponse bulkResponse = future.actionGet();
             assertNoFailures(bulkResponse);
 

diff --git a/test/framework/src/main/java/org/elasticsearch/test/ESIntegTestCase.java b/test/framework/src/main/java/org/elasticsearch/test/ESIntegTestCase.java
@@ -195,7 +195,6 @@
 import java.util.concurrent.ExecutionException;
 import java.util.concurrent.Executor;
 import java.util.concurrent.TimeUnit;
-import java.util.concurrent.atomic.AtomicBoolean;
 import java.util.concurrent.atomic.AtomicInteger;
 import java.util.concurrent.atomic.AtomicReference;
 import java.util.function.Function;
@@ -1797,7 +1796,8 @@ public void run() {
                                 handler.lastItems(docs, () -> {}, future);
                             } else {
                                 handler.addItems(docs, () -> {}, () -> {
-                                    if (runs.incrementAndGet() % 100 == 0) {
+                                    // Every 10 runs dispatch to new thread to prevent stackoverflow
+                                    if (runs.incrementAndGet() % 10 == 0) {
                                         new Thread(this).start();
                                     } else {
                                         this.run();