From 5284fc9f645ef19c363e46bdcea128d6ddb267d7 Mon Sep 17 00:00:00 2001 From: Lin Zhou Date: Thu, 10 Oct 2024 13:08:20 -0700 Subject: [PATCH] fix cdf --- .../scala/io/delta/sharing/server/DeltaSharingService.scala | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/server/src/main/scala/io/delta/sharing/server/DeltaSharingService.scala b/server/src/main/scala/io/delta/sharing/server/DeltaSharingService.scala index 58e650875..45a0e0e18 100644 --- a/server/src/main/scala/io/delta/sharing/server/DeltaSharingService.scala +++ b/server/src/main/scala/io/delta/sharing/server/DeltaSharingService.scala @@ -403,7 +403,8 @@ class DeltaSharingService(serverConfig: ServerConfig) { Option(startingTimestamp), Option(endingTimestamp) ), - includeHistoricalMetadata = Try(includeHistoricalMetadata.toBoolean).getOrElse(false) + includeHistoricalMetadata = Try(includeHistoricalMetadata.toBoolean).getOrElse(false), + includeEndStreamAction = includeEndStreamAction ) logger.info(s"Took ${System.currentTimeMillis - start} ms to load the table cdf " + s"and sign ${actions.length - 2} urls for table $share/$schema/$table")