测试线程池

cloud-task-server/src/main/java/com/muyu/service/impl/TaskServiceImpl.java

@@ -129,7 +129,7 @@ public class TaskServiceImpl extends ServiceImpl<TaskMapper, TaskInfo> implement
                     newAndOldMap.put(fieldAsNameMap.get(outPutFileName[o]), newFileName[o]);
                     if(tableAsFieldList[j].equals(outPutFileName[o])){
                         sql += ","+taskInputList.get(i).getTableAsName() + "." + tableFieldList[j] +" " +
-                                tableAsFieldList[j] + " ";
+                                tableAsFieldList[j] ;
                     }
                 }
 
@@ -238,6 +238,7 @@ public class TaskServiceImpl extends ServiceImpl<TaskMapper, TaskInfo> implement
     private void selectAndAdd(Long databaseId,Long basicId,String sql,Long tableId,
                               HashMap<String,String> newAndOldMap,Long finalFirstArray ,Integer two) {
             log.info("开始查询数据");
+            log.info("sql{}",sql);
             log.info("数组为{}，，{}",finalFirstArray ,two);
             DataValue[][] tableValue = dataValueClient.findTableValueToArray(databaseId, sql, finalFirstArray,two);
             log.info("远程调用完毕,调用数量{}",tableValue.length);