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)