Commit f4d3f688 by huangfusuper

重跑异常

parent b329ac9c
...@@ -69,7 +69,9 @@ public class ScriptMakeUpScriptTaskCallbackRunTheLifeCycleCallback implements Ta ...@@ -69,7 +69,9 @@ public class ScriptMakeUpScriptTaskCallbackRunTheLifeCycleCallback implements Ta
Map<String,String> publicParamMap = JSON.parseObject(publicParam, Map.class); Map<String,String> publicParamMap = JSON.parseObject(publicParam, Map.class);
String runParam = jobTaskSchedule.getRunParam(); String runParam = jobTaskSchedule.getRunParam();
RunParamWrapped runParamWrapped = JSON.parseObject(runParam, RunParamWrapped.class); RunParamWrapped runParamWrapped = JSON.parseObject(runParam, RunParamWrapped.class);
if (runParamWrapped == null) {
runParamWrapped = new RunParamWrapped();
}
String privateParam = runParamWrapped.getPrivateParam(); String privateParam = runParamWrapped.getPrivateParam();
ScriptParamAndPlaceholderDto scriptParamAndPlaceholderDto = JSON.parseObject(privateParam, ScriptParamAndPlaceholderDto.class); ScriptParamAndPlaceholderDto scriptParamAndPlaceholderDto = JSON.parseObject(privateParam, ScriptParamAndPlaceholderDto.class);
if(scriptParamAndPlaceholderDto == null) { if(scriptParamAndPlaceholderDto == null) {
......
...@@ -50,7 +50,7 @@ public class LogGobbler extends Thread { ...@@ -50,7 +50,7 @@ public class LogGobbler extends Thread {
Long aLong = stringRedisTemplate.opsForList().rightPush(runKey, JSON.toJSONString(runLog, WriteClassName)); Long aLong = stringRedisTemplate.opsForList().rightPush(runKey, JSON.toJSONString(runLog, WriteClassName));
log.info("-------{}-------",aLong); log.info("-------{}-------",aLong);
} }
printLog(line); //printLog(line);
} }
} catch (final IOException e) { } catch (final IOException e) {
log.error("Error reading from logging stream:", e); log.error("Error reading from logging stream:", e);
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment