From ae75b2716f8f32e5e8cc7637e20b95a07dbc8383 Mon Sep 17 00:00:00 2001 From: yebowen Date: Fri, 12 Apr 2024 11:00:33 +0800 Subject: [PATCH] fix test issue --- .../scala/com/_4paradigm/openmldb/batch/TestInsertPlan.scala | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/java/openmldb-batch/src/test/scala/com/_4paradigm/openmldb/batch/TestInsertPlan.scala b/java/openmldb-batch/src/test/scala/com/_4paradigm/openmldb/batch/TestInsertPlan.scala index 1832c61a185..99ddf4c9b3b 100644 --- a/java/openmldb-batch/src/test/scala/com/_4paradigm/openmldb/batch/TestInsertPlan.scala +++ b/java/openmldb-batch/src/test/scala/com/_4paradigm/openmldb/batch/TestInsertPlan.scala @@ -200,7 +200,7 @@ class TestInsertPlan extends SparkTestSuite { val testFileWithHeader = "file://" + getClass.getResource("/insert_test_src/test.csv") .getPath openmldbSession.sql(s"load data infile '$testFileWithHeader' into table $db.$table " + - s"options(format='csv', deep_copy=true);") + s"options(format='csv', mode='append', deep_copy=true);") val loadInfo = getLatestTableInfo(db, table) val oldFormat = loadInfo.getOfflineTableInfo.getFormat @@ -232,7 +232,7 @@ class TestInsertPlan extends SparkTestSuite { val testFileWithHeader = "file://" + getClass.getResource("/insert_test_src/test.csv") .getPath openmldbSession.sql(s"load data infile '$testFileWithHeader' into table $db.$table " + - "options(format='csv', deep_copy=false);") + "options(format='csv', mode='append', deep_copy=false);") val newSess = new OpenmldbSession(sparkSession) assertThrows[IllegalArgumentException](newSess.sql(s"insert into $db.$table values (1, 1, 1)")) }