Commit 51fb2c00 by fudahua

feat: 新版本的下载

parent e475d341
......@@ -107,7 +107,7 @@ public class FlatQueryResultServiceImpl implements IFlatQueryResultService {
private FlatQueryResultServiceImpl() {
log.debug("construct", "准备初始化 FlatQuery 查询服务");
// runDealHiveFile(3);
runDealHiveFile(3);
// runDistTask(3);
runDownloadTask(3);
runBalaDownloadTask(3);
......@@ -861,6 +861,7 @@ public class FlatQueryResultServiceImpl implements IFlatQueryResultService {
}
task.setStatus(DownloadTaskStatus.DOWNLOAD_HDFS);
task.setDownloadWay(-1);
task.setFieldSize(condition.getAllFields().size());
task.setDownloadTime(new Date());
//下载文件
String dirName="hdfs"+task.getId();
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment