From fe4e0b460187d342a8e0ce29118df34ea5b6617a Mon Sep 17 00:00:00 2001 From: weiye Date: Wed, 18 Dec 2019 18:28:22 +0800 Subject: [PATCH] =?UTF-8?q?=E6=89=A7=E8=A1=8C=E5=99=A8=E5=91=BD=E4=BB=A4?= =?UTF-8?q?=E6=B7=BB=E5=8A=A0=E5=8F=82=E6=95=B0?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../service/jobhandler/ExecutorJobHandler.java | 13 ++++++++++++- 1 file changed, 12 insertions(+), 1 deletion(-) diff --git a/datax-executor/src/main/java/com/wugui/datax/executor/service/jobhandler/ExecutorJobHandler.java b/datax-executor/src/main/java/com/wugui/datax/executor/service/jobhandler/ExecutorJobHandler.java index a21ec40a..3e607884 100644 --- a/datax-executor/src/main/java/com/wugui/datax/executor/service/jobhandler/ExecutorJobHandler.java +++ b/datax-executor/src/main/java/com/wugui/datax/executor/service/jobhandler/ExecutorJobHandler.java @@ -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 params=new HashMap<>(); + params.put("-j","-Xms2G -Xmx2G"); + //params.put("--jvm","-Xms2G"+"\" \""+"-Xmx2G"); + String doc=""; + for (Map.Entry 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);