diff options
| -rw-r--r-- | galaxy-job-executor/src/main/java/com/mesalab/executor/jobhandler/DruidCompactJob.java | 16 |
1 files changed, 10 insertions, 6 deletions
diff --git a/galaxy-job-executor/src/main/java/com/mesalab/executor/jobhandler/DruidCompactJob.java b/galaxy-job-executor/src/main/java/com/mesalab/executor/jobhandler/DruidCompactJob.java index 2e5ab9f..195ab10 100644 --- a/galaxy-job-executor/src/main/java/com/mesalab/executor/jobhandler/DruidCompactJob.java +++ b/galaxy-job-executor/src/main/java/com/mesalab/executor/jobhandler/DruidCompactJob.java @@ -33,15 +33,19 @@ public class DruidCompactJob { @XxlJob("druidCompactSegmentJobHandler") - public ReturnT<String> druidCompactSegmentJobHandler (String param) { + public ReturnT<String> druidCompactSegmentJobHandler (String params) { try{ - if (StringUtil.isEmpty(param)){ - logger.error("params parser error , params is {}", param); + if (StringUtil.isEmpty(params)){ + logger.error("params parser error , params is {}", params); return IJobHandler.FAIL; } - DruidNativeCompactParam druidNativeCompactParam = (DruidNativeCompactParam)JsonMapper.fromJsonString(param, DruidNativeCompactParam.class); - //传入json为http的请求体 - jsonForRequestBodyToHttp(druidNativeCompactParam); + //参数不为空，多参数切割并分别传入post请求中 + String[] paramOfPost = params.split(";"); + for (String param:paramOfPost) { + DruidNativeCompactParam druidNativeCompactParam = (DruidNativeCompactParam)JsonMapper.fromJsonString(param, DruidNativeCompactParam.class); + //传入json为http的请求体 + jsonForRequestBodyToHttp(druidNativeCompactParam); + } }catch (Exception e){ logger.error(e.getMessage()); XxlJobLogger.log(e.getMessage()); |