Skip to content

Commit

Permalink
Update FileLoadTest.java
Browse files Browse the repository at this point in the history
  • Loading branch information
imbajin committed Mar 24, 2023
1 parent 010367c commit 87c95a2
Showing 1 changed file with 2 additions and 2 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -2425,10 +2425,10 @@ public void testParquetCompressFile() {
"--batch-insert-threads", "2",
"--test-mode", "true"
};
String path = configPath("parquet_compress_file/vertex_person.parquet");
CommonUtil.downloadFileByUrl(CommonUtil.PREFIX + "vertex_person.parquet", path);
if (this.ioUtil instanceof HDFSUtil) {
HDFSUtil hdfsUtil = (HDFSUtil) this.ioUtil;
String path = configPath("parquet_compress_file/vertex_person.parquet");
CommonUtil.downloadFileByUrl(CommonUtil.PREFIX + "vertex_person.parquet", path);
CommonUtil.downloadFileByUrl(CommonUtil.PREFIX + "vertex_person.parquet",
"src/test/resources/parquet_compress_file/vertex_person.parquet");
hdfsUtil.copy(path, "hdfs://localhost:8020/files/vertex_person.parquet");
Expand Down

0 comments on commit 87c95a2

Please sign in to comment.