(iceberg) branch main updated: Spark 4.1: Simplify time travel option extraction in IcebergSource (#15375)

[aokolnychyi]

This is an automated email from the ASF dual-hosted git repository.

aokolnychyi pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/iceberg.git


The following commit(s) were added to refs/heads/main by this push:
     new cb0c9ccd40 Spark 4.1: Simplify time travel option extraction in 
IcebergSource (#15375)
cb0c9ccd40 is described below

commit cb0c9ccd40f1989450782d95a55d5e6aee26cb23
Author: Anton Okolnychyi <aokolnyc...@apache.org>
AuthorDate: Thu Feb 19 22:33:46 2026 -0800

    Spark 4.1: Simplify time travel option extraction in IcebergSource (#15375)
---
 .../main/java/org/apache/iceberg/spark/source/IcebergSource.java   | 7 ++-----
 1 file changed, 2 insertions(+), 5 deletions(-)

diff --git 
a/spark/v4.1/spark/src/main/java/org/apache/iceberg/spark/source/IcebergSource.java
 
b/spark/v4.1/spark/src/main/java/org/apache/iceberg/spark/source/IcebergSource.java
index 28282eb1cc..e2b8c072d1 100644
--- 
a/spark/v4.1/spark/src/main/java/org/apache/iceberg/spark/source/IcebergSource.java
+++ 
b/spark/v4.1/spark/src/main/java/org/apache/iceberg/spark/source/IcebergSource.java
@@ -32,7 +32,6 @@ import org.apache.iceberg.spark.SparkReadOptions;
 import org.apache.iceberg.spark.SparkRewriteTableCatalog;
 import org.apache.iceberg.spark.SparkSessionCatalog;
 import org.apache.iceberg.spark.SparkTableCache;
-import org.apache.iceberg.util.PropertyUtil;
 import org.apache.spark.sql.SparkSession;
 import org.apache.spark.sql.catalyst.analysis.NoSuchTableException;
 import org.apache.spark.sql.connector.catalog.CatalogManager;
@@ -215,14 +214,12 @@ public class IcebergSource
 
   @Override
   public Optional<String> extractTimeTravelVersion(CaseInsensitiveStringMap 
options) {
-    return Optional.ofNullable(
-        PropertyUtil.propertyAsString(options, SparkReadOptions.VERSION_AS_OF, 
null));
+    return Optional.ofNullable(options.get(SparkReadOptions.VERSION_AS_OF));
   }
 
   @Override
   public Optional<String> extractTimeTravelTimestamp(CaseInsensitiveStringMap 
options) {
-    return Optional.ofNullable(
-        PropertyUtil.propertyAsString(options, 
SparkReadOptions.TIMESTAMP_AS_OF, null));
+    return Optional.ofNullable(options.get(SparkReadOptions.TIMESTAMP_AS_OF));
   }
 
   private static Long propertyAsLong(CaseInsensitiveStringMap options, String 
property) {