diff --git a/common/workflow-core/src/main/scala/org/apache/texera/service/util/S3StorageClient.scala b/common/workflow-core/src/main/scala/org/apache/texera/service/util/S3StorageClient.scala index f3d252d413b..d692c574b8e 100644 --- a/common/workflow-core/src/main/scala/org/apache/texera/service/util/S3StorageClient.scala +++ b/common/workflow-core/src/main/scala/org/apache/texera/service/util/S3StorageClient.scala @@ -38,7 +38,8 @@ import scala.jdk.CollectionConverters._ object S3StorageClient { val MINIMUM_NUM_OF_MULTIPART_S3_PART: Long = 5L * 1024 * 1024 // 5 MiB val MAXIMUM_NUM_OF_MULTIPART_S3_PARTS = 10_000 - val PHYSICAL_ADDRESS_EXPIRATION_TIME_HRS = 6 + //Keep on sync with LakeFS https://github.com/treeverse/lakeFS/pull/10180 + val PHYSICAL_ADDRESS_EXPIRATION_TIME_HRS = 24 // Initialize MinIO-compatible S3 Client private lazy val s3Client: S3Client = { diff --git a/file-service/src/test/scala/org/apache/texera/service/resource/DatasetResourceSpec.scala b/file-service/src/test/scala/org/apache/texera/service/resource/DatasetResourceSpec.scala index 24253c3a92d..0256fbf4937 100644 --- a/file-service/src/test/scala/org/apache/texera/service/resource/DatasetResourceSpec.scala +++ b/file-service/src/test/scala/org/apache/texera/service/resource/DatasetResourceSpec.scala @@ -905,7 +905,7 @@ class DatasetResourceSpec uploadPart(filePath, 1, minPartBytes(1.toByte)).getStatus shouldEqual 200 fetchPartRows(oldUploadId).find(_.getPartNumber == 1).get.getEtag.trim should not be "" - // Age the session so it is definitely expired (> PHYSICAL_ADDRESS_EXPIRATION_TIME_HRS = 6) + // Age the session so it is definitely expired (> PHYSICAL_ADDRESS_EXPIRATION_TIME_HRS) val expireHrs = S3StorageClient.PHYSICAL_ADDRESS_EXPIRATION_TIME_HRS getDSLContext