From 70f99e2104ccafca77b9f7a85efc1072d0ed9162 Mon Sep 17 00:00:00 2001 From: Lin Zhou Date: Wed, 9 Oct 2024 16:33:48 -0700 Subject: [PATCH] two nit fixes --- .../io/delta/sharing/server/DeltaSharingServiceSuite.scala | 4 +--- .../scala/io/delta/sharing/spark/TestDeltaSharingClient.scala | 2 +- 2 files changed, 2 insertions(+), 4 deletions(-) diff --git a/server/src/test/scala/io/delta/sharing/server/DeltaSharingServiceSuite.scala b/server/src/test/scala/io/delta/sharing/server/DeltaSharingServiceSuite.scala index 04c7b0f01..e034a62b0 100644 --- a/server/src/test/scala/io/delta/sharing/server/DeltaSharingServiceSuite.scala +++ b/server/src/test/scala/io/delta/sharing/server/DeltaSharingServiceSuite.scala @@ -708,10 +708,8 @@ class DeltaSharingServiceSuite extends FunSuite with BeforeAndAfterAll { asyncQuery = "true" ) - var lines = response.split("\n") + val lines = response.split("\n") assert(lines.length == 4) - - print(s"response: $response") } } diff --git a/spark/src/test/scala/io/delta/sharing/spark/TestDeltaSharingClient.scala b/spark/src/test/scala/io/delta/sharing/spark/TestDeltaSharingClient.scala index 3cb125fe8..1fa0a5193 100644 --- a/spark/src/test/scala/io/delta/sharing/spark/TestDeltaSharingClient.scala +++ b/spark/src/test/scala/io/delta/sharing/spark/TestDeltaSharingClient.scala @@ -47,7 +47,7 @@ class TestDeltaSharingClient( readerFeatures: String = "", queryTablePaginationEnabled: Boolean = false, maxFilesPerReq: Int = 10000, - includeEndStreamAction: Boolean = false, + endStreamActionEnabled: Boolean = true, enableAsyncQuery: Boolean = false, asyncQueryPollIntervalMillis: Long = 1000L, asyncQueryMaxDuration: Long = Long.MaxValue,