diff --git a/src/java/net/unit8/job_streamer/control_bus/JobStreamerExecuteJob.java b/src/java/net/unit8/job_streamer/control_bus/JobStreamerExecuteJob.java index d1c3ea7..458ed86 100644 --- a/src/java/net/unit8/job_streamer/control_bus/JobStreamerExecuteJob.java +++ b/src/java/net/unit8/job_streamer/control_bus/JobStreamerExecuteJob.java @@ -24,8 +24,11 @@ public void execute(JobExecutionContext context) throws JobExecutionException { JobDataMap data = context.getMergedJobDataMap(); String jobName = data.getString("job-name"); String appName = data.getString("app-name"); - if (jobName == null || appName == null) return; logger.info("execute job that " + "jobName:" + jobName + " appName:" + appName + " execution-id:" + data.getString("execution-id") + " command:" + data.getString("command")); + if (jobName == null || appName == null) { + logger.warn("not execute invalid job. look back the setting"); + return; + } Object system = SystemUtil.getSystem(); Object jobs = RT.get(system, Keyword.intern("jobs"));