Skip to content

Commit

Permalink
update
Browse files Browse the repository at this point in the history
  • Loading branch information
Zouxxyy committed Nov 8, 2024
1 parent 6bcfe7e commit a29dc9b
Showing 1 changed file with 2 additions and 2 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -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)
Expand Down

0 comments on commit a29dc9b

Please sign in to comment.