From 0fb85bf5ed1063c15124a8d0e2babd2b157c5d19 Mon Sep 17 00:00:00 2001
From: benmoriceau <benoit@airbyte.io>
Date: Mon, 2 Oct 2023 14:35:01 -0700
Subject: [PATCH] limit parallelism to 1

---
 .../cdk/integrations/destination_async/FlushWorkers.java        | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/airbyte-cdk/java/airbyte-cdk/core/src/main/java/io/airbyte/cdk/integrations/destination_async/FlushWorkers.java b/airbyte-cdk/java/airbyte-cdk/core/src/main/java/io/airbyte/cdk/integrations/destination_async/FlushWorkers.java
index 3d4d03a6fc36..a96779cb6b59 100644
--- a/airbyte-cdk/java/airbyte-cdk/core/src/main/java/io/airbyte/cdk/integrations/destination_async/FlushWorkers.java
+++ b/airbyte-cdk/java/airbyte-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);