Merge remote-tracking branch 'origin/develop' into dev-fix-eal4dev-fix-eal4

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());