You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iceberg.apache.org by am...@apache.org on 2024/11/13 21:09:39 UTC
(iceberg) branch main updated: Spark: Update tests which assume file format to use enum instead of string literal (#11540)
This is an automated email from the ASF dual-hosted git repository.
amoghj 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 3659ded18d Spark: Update tests which assume file format to use enum instead of string literal (#11540)
3659ded18d is described below
commit 3659ded18d50206576985339bd55cd82f5e200cc
Author: Huaxin Gao <hu...@gmail.com>
AuthorDate: Wed Nov 13 13:09:31 2024 -0800
Spark: Update tests which assume file format to use enum instead of string literal (#11540)
---
.../java/org/apache/iceberg/spark/source/TestSparkReaderDeletes.java | 2 +-
.../java/org/apache/iceberg/spark/source/TestSparkReaderDeletes.java | 2 +-
.../java/org/apache/iceberg/spark/source/TestSparkReaderDeletes.java | 2 +-
3 files changed, 3 insertions(+), 3 deletions(-)
diff --git a/spark/v3.3/spark/src/test/java/org/apache/iceberg/spark/source/TestSparkReaderDeletes.java b/spark/v3.3/spark/src/test/java/org/apache/iceberg/spark/source/TestSparkReaderDeletes.java
index bde87778ad..5ba296e74c 100644
--- a/spark/v3.3/spark/src/test/java/org/apache/iceberg/spark/source/TestSparkReaderDeletes.java
+++ b/spark/v3.3/spark/src/test/java/org/apache/iceberg/spark/source/TestSparkReaderDeletes.java
@@ -545,7 +545,7 @@ public class TestSparkReaderDeletes extends DeleteReadTests {
@TestTemplate
public void testPosDeletesOnParquetFileWithMultipleRowGroups() throws IOException {
- assumeThat(format).isEqualTo("parquet");
+ assumeThat(format).isEqualTo(FileFormat.PARQUET);
String tblName = "test3";
Table tbl = createTable(tblName, SCHEMA, PartitionSpec.unpartitioned());
diff --git a/spark/v3.4/spark/src/test/java/org/apache/iceberg/spark/source/TestSparkReaderDeletes.java b/spark/v3.4/spark/src/test/java/org/apache/iceberg/spark/source/TestSparkReaderDeletes.java
index 29c2d4b39a..285a210db5 100644
--- a/spark/v3.4/spark/src/test/java/org/apache/iceberg/spark/source/TestSparkReaderDeletes.java
+++ b/spark/v3.4/spark/src/test/java/org/apache/iceberg/spark/source/TestSparkReaderDeletes.java
@@ -554,7 +554,7 @@ public class TestSparkReaderDeletes extends DeleteReadTests {
@TestTemplate
public void testPosDeletesOnParquetFileWithMultipleRowGroups() throws IOException {
- assumeThat(format).isEqualTo("parquet");
+ assumeThat(format).isEqualTo(FileFormat.PARQUET);
String tblName = "test3";
Table tbl = createTable(tblName, SCHEMA, PartitionSpec.unpartitioned());
diff --git a/spark/v3.5/spark/src/test/java/org/apache/iceberg/spark/source/TestSparkReaderDeletes.java b/spark/v3.5/spark/src/test/java/org/apache/iceberg/spark/source/TestSparkReaderDeletes.java
index 29c2d4b39a..285a210db5 100644
--- a/spark/v3.5/spark/src/test/java/org/apache/iceberg/spark/source/TestSparkReaderDeletes.java
+++ b/spark/v3.5/spark/src/test/java/org/apache/iceberg/spark/source/TestSparkReaderDeletes.java
@@ -554,7 +554,7 @@ public class TestSparkReaderDeletes extends DeleteReadTests {
@TestTemplate
public void testPosDeletesOnParquetFileWithMultipleRowGroups() throws IOException {
- assumeThat(format).isEqualTo("parquet");
+ assumeThat(format).isEqualTo(FileFormat.PARQUET);
String tblName = "test3";
Table tbl = createTable(tblName, SCHEMA, PartitionSpec.unpartitioned());