Test

airbytehq · Oct 25, 2024 · 71e35d3 · 71e35d3
1 parent d8a3bb0
commit 71e35d3
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...core/src/main/kotlin/io/airbyte/cdk/integrations/destination/async/DetectStreamToFlush.kt b/...core/src/main/kotlin/io/airbyte/cdk/integrations/destination/async/DetectStreamToFlush.kt
@@ -70,7 +70,7 @@ internal constructor(
                 bufferDequeue.totalGlobalQueueSizeBytes.toDouble() / bufferDequeue.maxQueueSizeBytes
         // when we are closing or queues are very full, flush regardless of how few items are in the
         // queue.
-        return if (isClosing.get() || isBuffer90Full) 0 else flusher.queueFlushThresholdBytes
+        return 0;//if (isClosing.get() || isBuffer90Full) 0 else flusher.queueFlushThresholdBytes
     }
 
     // todo (cgardens) - improve prioritization by getting a better estimate of how much data