From 71e35d33480d01c6cee379d79f04d58109ddd3b1 Mon Sep 17 00:00:00 2001 From: benmoriceau Date: Fri, 25 Oct 2024 14:46:19 -0700 Subject: [PATCH] Test --- .../cdk/integrations/destination/async/DetectStreamToFlush.kt | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/airbyte-cdk/java/airbyte-cdk/core/src/main/kotlin/io/airbyte/cdk/integrations/destination/async/DetectStreamToFlush.kt b/airbyte-cdk/java/airbyte-cdk/core/src/main/kotlin/io/airbyte/cdk/integrations/destination/async/DetectStreamToFlush.kt index db61cdaebf45d..4b2da3c86381f 100644 --- a/airbyte-cdk/java/airbyte-cdk/core/src/main/kotlin/io/airbyte/cdk/integrations/destination/async/DetectStreamToFlush.kt +++ b/airbyte-cdk/java/airbyte-cdk/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