From 0f9e0598f88057e3568bffca85e9059af74a122b Mon Sep 17 00:00:00 2001 From: tryangul Date: Tue, 10 Dec 2024 14:43:41 -0800 Subject: [PATCH] Add comment. --- .../kotlin/io/airbyte/cdk/load/task/internal/SpillToDiskTask.kt | 1 + 1 file changed, 1 insertion(+) diff --git a/airbyte-cdk/bulk/core/load/src/main/kotlin/io/airbyte/cdk/load/task/internal/SpillToDiskTask.kt b/airbyte-cdk/bulk/core/load/src/main/kotlin/io/airbyte/cdk/load/task/internal/SpillToDiskTask.kt index a20d3704ac447..1760dd5b6c536 100644 --- a/airbyte-cdk/bulk/core/load/src/main/kotlin/io/airbyte/cdk/load/task/internal/SpillToDiskTask.kt +++ b/airbyte-cdk/bulk/core/load/src/main/kotlin/io/airbyte/cdk/load/task/internal/SpillToDiskTask.kt @@ -149,6 +149,7 @@ class DefaultSpillToDiskTask( publishFile(file) } + // this result should not be used as upstream will close the channel. return FileAccumulator( spillFile, outputStream,