diff --git a/.github/scripts/test/cli/test_infile.sh b/.github/scripts/test/cli/test_infile.sh index 1d85857026..784cc3299d 100644 --- a/.github/scripts/test/cli/test_infile.sh +++ b/.github/scripts/test/cli/test_infile.sh @@ -32,6 +32,6 @@ bash -c "cat 'test/src/test/resources/fileReadAndWrite/csv/test.csv' > 'test/src bash -c "sed -i '1ikey,d m,b,[c],a' 'test/src/test/resources/fileReadAndWrite/csv/test1'" -COMMAND1='LOAD DATA FROM INFILE "'"test/src/test/resources/fileReadAndWrite/csv/test1"'" AS CSV INTO t1;' +COMMAND1='LOAD DATA FROM INFILE "'"test/src/test/resources/fileReadAndWrite/csv/test1"'" AS CSV INTO t1 AT 10;' bash -c "echo '$COMMAND1' | xargs -0 -t -i ${SCRIPT_COMMAND}" diff --git a/.github/scripts/test/cli/test_infile_macos.sh b/.github/scripts/test/cli/test_infile_macos.sh index 2168df4a31..5a5122b7b6 100644 --- a/.github/scripts/test/cli/test_infile_macos.sh +++ b/.github/scripts/test/cli/test_infile_macos.sh @@ -28,4 +28,4 @@ sh -c "cat test/src/test/resources/fileReadAndWrite/csv/test.csv > test/src/test sh -c "sed -i '' '1s/^/key,d m,b,[c],a\n/' test/src/test/resources/fileReadAndWrite/csv/test1" -sh -c "echo 'LOAD DATA FROM INFILE "'"test/src/test/resources/fileReadAndWrite/csv/test1"'" AS CSV INTO t1;' | xargs -0 -t -I F sh client/target/iginx-client-$1/sbin/start_cli.sh -e 'F'" +sh -c "echo 'LOAD DATA FROM INFILE "'"test/src/test/resources/fileReadAndWrite/csv/test1"'" AS CSV INTO t1 AT 10;' | xargs -0 -t -I F sh client/target/iginx-client-$1/sbin/start_cli.sh -e 'F'" diff --git a/test/src/test/java/cn/edu/tsinghua/iginx/integration/client/ImportFileIT.java b/test/src/test/java/cn/edu/tsinghua/iginx/integration/client/ImportFileIT.java index 66c03c6442..99391e3b07 100644 --- a/test/src/test/java/cn/edu/tsinghua/iginx/integration/client/ImportFileIT.java +++ b/test/src/test/java/cn/edu/tsinghua/iginx/integration/client/ImportFileIT.java @@ -73,11 +73,11 @@ public void testLoadData() { + "+---+------+----+----+------+\n" + "|key|t1._c_|t1.a|t1.b|t1.d_m|\n" + "+---+------+----+----+------+\n" - + "| 0| true| aaa| 0.5| 0.0|\n" - + "| 1| false| bbb| 1.5| 1.0|\n" - + "| 2| true| ccc| 2.5| 2.0|\n" - + "| 3| false| ddd| 3.5| 3.0|\n" - + "| 4| true| eee| 4.5| 4.0|\n" + + "| 10| true| aaa| 0.5| 0.0|\n" + + "| 11| false| bbb| 1.5| 1.0|\n" + + "| 12| true| ccc| 2.5| 2.0|\n" + + "| 13| false| ddd| 3.5| 3.0|\n" + + "| 14| true| eee| 4.5| 4.0|\n" + "+---+------+----+----+------+\n" + "Total line number = 5\n"; executor.executeAndCompare(query, expected);