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 c51dda5447 Spark 4.1: Use enum conf parser for isolation level (#15361)
c51dda5447 is described below
commit c51dda5447daa04a0964871bb2ff779ed95fee6e
Author: Anton Okolnychyi <[email protected]>
AuthorDate: Wed Feb 18 22:54:34 2026 -0800
Spark 4.1: Use enum conf parser for isolation level (#15361)
---
.../src/main/java/org/apache/iceberg/spark/SparkWriteConf.java | 7 ++++---
1 file changed, 4 insertions(+), 3 deletions(-)
diff --git
a/spark/v4.1/spark/src/main/java/org/apache/iceberg/spark/SparkWriteConf.java
b/spark/v4.1/spark/src/main/java/org/apache/iceberg/spark/SparkWriteConf.java
index d74754e4d3..1e937863c3 100644
---
a/spark/v4.1/spark/src/main/java/org/apache/iceberg/spark/SparkWriteConf.java
+++
b/spark/v4.1/spark/src/main/java/org/apache/iceberg/spark/SparkWriteConf.java
@@ -449,9 +449,10 @@ public class SparkWriteConf {
}
public IsolationLevel isolationLevel() {
- String isolationLevelName =
-
confParser.stringConf().option(SparkWriteOptions.ISOLATION_LEVEL).parseOptional();
- return isolationLevelName != null ?
IsolationLevel.fromName(isolationLevelName) : null;
+ return confParser
+ .enumConf(IsolationLevel::fromName)
+ .option(SparkWriteOptions.ISOLATION_LEVEL)
+ .parseOptional();
}
public boolean caseSensitive() {