CodeCow/datax-web
1
0
Fork 0
mirror of https://github.com/WeiYe-Jing/datax-web.git synced 2026-06-30 21:17:37 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

执行器命令添加参数

Browse Source
This commit is contained in:
weiye 2019-12-18 18:28:22 +08:00
parent b0190b289f
commit fe4e0b4601
1 changed files with 12 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
datax-executor/src/main/java/com/wugui/datax/executor/service/jobhandler/ExecutorJobHandler.java
View File

@ -14,6 +14,8 @@ import org.springframework.stereotype.Component;
import java.io.*;
import java.nio.charset.StandardCharsets;
import java.util.HashMap;
import java.util.Map;
/**
* DataX任务运行
@ -41,8 +43,17 @@ public class ExecutorJobHandler extends IJobHandler {
//生成Json临时文件
tmpFilePath = generateTemJsonFile(tgParam.getJobJson());
try {
Map<String,String> params=new HashMap<>();
params.put("-j","-Xms2G -Xmx2G");
//params.put("--jvm","-Xms2G"+"\" \""+"-Xmx2G");
String doc="";
for (Map.Entry<String, String> entry : params.entrySet()) {
doc=entry.getKey()+"\""+entry.getValue()+"\"";
//doc=entry.getKey()+"\" \""+"\""+entry.getValue()+"\"";
}
// command process
Process process = Runtime.getRuntime().exec(new String[]{"python",dataXPyPath, tmpFilePath});
System.out.println(doc);
Process process = Runtime.getRuntime().exec(new String[]{"python",dataXPyPath,doc.replaceAll(" ", "\" \""), tmpFilePath});
String processId = ProcessUtil.getProcessId(process);
JobLogger.log("------------------DataX运行进程Id: " + processId);
jobTmpFiles.put(processId, tmpFilePath);