From 3a6804472de0e26ac9471526e98df5b67e8816bb Mon Sep 17 00:00:00 2001 From: liliwei Date: Tue, 9 Aug 2022 14:20:16 +0800 Subject: [PATCH] Spark 3.1:Port #3491 to Spark 3.1 --- .../src/main/java/org/apache/iceberg/spark/SparkWriteConf.java | 2 +- .../main/java/org/apache/iceberg/spark/SparkWriteOptions.java | 2 ++ 2 files changed, 3 insertions(+), 1 deletion(-) diff --git a/spark/v3.1/spark/src/main/java/org/apache/iceberg/spark/SparkWriteConf.java b/spark/v3.1/spark/src/main/java/org/apache/iceberg/spark/SparkWriteConf.java index 08b3fbee7590..5e007bdebcbe 100644 --- a/spark/v3.1/spark/src/main/java/org/apache/iceberg/spark/SparkWriteConf.java +++ b/spark/v3.1/spark/src/main/java/org/apache/iceberg/spark/SparkWriteConf.java @@ -99,7 +99,7 @@ public boolean handleTimestampWithoutZone() { } public String overwriteMode() { - String overwriteMode = writeOptions.get("overwrite-mode"); + String overwriteMode = writeOptions.get(SparkWriteOptions.OVERWRITE_MODE); return overwriteMode != null ? overwriteMode.toLowerCase(Locale.ROOT) : null; } diff --git a/spark/v3.1/spark/src/main/java/org/apache/iceberg/spark/SparkWriteOptions.java b/spark/v3.1/spark/src/main/java/org/apache/iceberg/spark/SparkWriteOptions.java index 0ba435ae7429..ef25f871aed7 100644 --- a/spark/v3.1/spark/src/main/java/org/apache/iceberg/spark/SparkWriteOptions.java +++ b/spark/v3.1/spark/src/main/java/org/apache/iceberg/spark/SparkWriteOptions.java @@ -50,4 +50,6 @@ private SparkWriteOptions() {} // Controls whether to allow writing timestamps without zone info public static final String HANDLE_TIMESTAMP_WITHOUT_TIMEZONE = "handle-timestamp-without-timezone"; + + public static final String OVERWRITE_MODE = "overwrite-mode"; }