fix setIncludeEndStreamAction

delta-io · Oct 11, 2024 · 967c479 · 967c479
1 parent 2e79c9d
commit 967c479
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/client/src/main/scala/io/delta/sharing/client/DeltaSharingClient.scala b/client/src/main/scala/io/delta/sharing/client/DeltaSharingClient.scala
@@ -471,7 +471,7 @@ class DeltaSharingRestClient(
       val (version, respondedFormat, lines) = getNDJsonPost(
         target,
         request,
-        setIncludeEndStreamAction = true
+        setIncludeEndStreamAction = endStreamActionEnabled
       )
       val (filteredLines, _) = maybeExtractEndStreamAction(lines)
       (version, respondedFormat, filteredLines)