Fix endStreamActionEnabled in DeltaSharingClient

delta-io · Oct 26, 2024 · 9bc3e9f · 9bc3e9f
1 parent b937f10
commit 9bc3e9f
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 4 deletions.
diff --git a/client/src/main/scala/io/delta/sharing/client/DeltaSharingClient.scala b/client/src/main/scala/io/delta/sharing/client/DeltaSharingClient.scala
@@ -425,7 +425,8 @@ class DeltaSharingRestClient(
         respondedFormat = respondedFormat
       )
     }
-    require(versionAsOf.isEmpty || versionAsOf.get == version)
+    require(versionAsOf.isEmpty || versionAsOf.get == version,
+      s"versionAsOf: $versionAsOf, version:$version")
     val protocol = JsonUtils.fromJson[SingleAction](lines(0)).protocol
     checkProtocol(protocol)
     val metadata = JsonUtils.fromJson[SingleAction](lines(1)).metaData
@@ -1355,8 +1356,8 @@ object DeltaSharingRestClient extends Logging {
         readerFeatures,
         java.lang.Boolean.valueOf(queryTablePaginationEnabled),
         java.lang.Integer.valueOf(maxFilesPerReq),
-        java.lang.Boolean.valueOf(useAsyncQuery),
         java.lang.Boolean.valueOf(endStreamActionEnabled),
+        java.lang.Boolean.valueOf(useAsyncQuery),
         java.lang.Long.valueOf(asyncQueryPollDurationMillis),
         java.lang.Long.valueOf(asyncQueryMaxDurationMillis),
         java.lang.Integer.valueOf(tokenExchangeMaxRetries),

diff --git a/server/src/main/scala/io/delta/sharing/server/DeltaSharingService.scala b/server/src/main/scala/io/delta/sharing/server/DeltaSharingService.scala
@@ -499,8 +499,6 @@ class DeltaSharingService(serverConfig: ServerConfig) {
       val responseFormatSet = getResponseFormatSet(capabilitiesMap)
       val clientReaderFeaturesSet = getReaderFeatures(capabilitiesMap)
       val includeEndStreamAction = getRequestEndStreamAction(capabilitiesMap)
-      // scalastyle:off println
-      Console.println(s"----[linzhou]----Service,includeEndStreamAction:$includeEndStreamAction")
       val queryResult = if (
         request.predicateHints.isEmpty
           && request.maxFiles.isEmpty