From a29dc9baff5910e450413217272c718e655d7963 Mon Sep 17 00:00:00 2001 From: zouxxyy Date: Fri, 8 Nov 2024 19:14:52 +0800 Subject: [PATCH] update --- .../org/apache/paimon/spark/SparkCatalogWithHiveTest.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/paimon-spark/paimon-spark-common/src/test/java/org/apache/paimon/spark/SparkCatalogWithHiveTest.java b/paimon-spark/paimon-spark-common/src/test/java/org/apache/paimon/spark/SparkCatalogWithHiveTest.java index d42e84b9cfdd..370ea35a88ab 100644 --- a/paimon-spark/paimon-spark-common/src/test/java/org/apache/paimon/spark/SparkCatalogWithHiveTest.java +++ b/paimon-spark/paimon-spark-common/src/test/java/org/apache/paimon/spark/SparkCatalogWithHiveTest.java @@ -98,10 +98,10 @@ public void testCreateFormatTable(@TempDir java.nio.file.Path tempDir) { // test csv table spark.sql( - "CREATE TABLE IF NOT EXISTS table_csv (a INT, bb INT, c STRING) USING csv OPTIONS ('field-delimiter' ';')"); + "CREATE TABLE IF NOT EXISTS table_csv (a INT, bb INT, c STRING) USING csv OPTIONS ('field-delimiter' ',')"); spark.sql("INSERT INTO table_csv VALUES (1, 1, '1'), (2, 2, '2')").collect(); assertThat(spark.sql("DESCRIBE FORMATTED table_csv").collectAsList().toString()) - .contains("sep=;"); + .contains("sep=,"); assertThat( spark.sql("SELECT * FROM table_csv").collectAsList().stream() .map(Row::toString)