This is an automated email from the ASF dual-hosted git repository. lzljs3620320 pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/incubator-paimon.git
commit 578c4085ad8fb2a012c3f9cb092fe711f4a1e1b5 Author: waywtdcc <[email protected]> AuthorDate: Tue Aug 1 13:49:05 2023 +0800 [spark] Add test for truncate table --- .../test/java/org/apache/paimon/spark/SparkWriteITCase.java | 13 ++++++++++++- 1 file changed, 12 insertions(+), 1 deletion(-) diff --git a/paimon-spark/paimon-spark-common/src/test/java/org/apache/paimon/spark/SparkWriteITCase.java b/paimon-spark/paimon-spark-common/src/test/java/org/apache/paimon/spark/SparkWriteITCase.java index bbe85c11b..999b28c1e 100644 --- a/paimon-spark/paimon-spark-common/src/test/java/org/apache/paimon/spark/SparkWriteITCase.java +++ b/paimon-spark/paimon-spark-common/src/test/java/org/apache/paimon/spark/SparkWriteITCase.java @@ -42,7 +42,7 @@ public class SparkWriteITCase { @BeforeAll public void startMetastoreAndSpark(@TempDir java.nio.file.Path tempDir) { - Path warehousePath = new Path("file:" + tempDir.toString()); + Path warehousePath = new Path("file:///" + tempDir.toString()); spark = SparkSession.builder().master("local[2]").getOrCreate(); spark.conf().set("spark.sql.catalog.paimon", SparkCatalog.class.getName()); spark.conf().set("spark.sql.catalog.paimon.warehouse", warehousePath.toString()); @@ -119,6 +119,17 @@ public class SparkWriteITCase { assertThat(rows.toString()).isEqualTo("[[2,22,222]]"); } + @Test + public void testTruncateTable() { + spark.sql( + "CREATE TABLE T (a INT, b INT, c STRING) TBLPROPERTIES" + + " ('primary-key'='a', 'file.format'='avro')"); + spark.sql("INSERT INTO T VALUES (1, 11, '111'), (2, 22, '222')").collectAsList(); + spark.sql("TRUNCATE TABLE T").collectAsList(); + List<Row> rows = spark.sql("SELECT * FROM T").collectAsList(); + assertThat(rows.toString()).isEqualTo("[]"); + } + @Test public void testWriteDynamicBucketPartitionedTable() { spark.sql(
