diff --git a/client/src/main/scala/io/delta/sharing/client/DeltaSharingClient.scala b/client/src/main/scala/io/delta/sharing/client/DeltaSharingClient.scala
index 760bc498b..f8558863f 100644
--- 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)