limit parallelism to 1

airbytehq · Oct 2, 2023 · 0fb85bf · 0fb85bf
1 parent 5ecb097
commit 0fb85bf
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...te-cdk/core/src/main/java/io/airbyte/cdk/integrations/destination_async/FlushWorkers.java b/...te-cdk/core/src/main/java/io/airbyte/cdk/integrations/destination_async/FlushWorkers.java
@@ -79,7 +79,7 @@ public FlushWorkers(final BufferDequeue bufferDequeue,
     flusher = flushFunction;
     debugLoop = Executors.newSingleThreadScheduledExecutor();
     supervisorThread = Executors.newScheduledThreadPool(1);
-    workerPool = Executors.newFixedThreadPool(2);
+    workerPool = Executors.newFixedThreadPool(1);
     isClosing = new AtomicBoolean(false);
     runningFlushWorkers = new RunningFlushWorkers();
     detectStreamToFlush = new DetectStreamToFlush(bufferDequeue, runningFlushWorkers, isClosing, flusher);