apache / shardingsphere-elasticjob-cloud Goto Github PK

private Date getOnlineDate() {
        SimpleDateFormat formatter = new SimpleDateFormat("yyyy-MM-dd");
        try {
            return formatter.parse("2016-12-16");
        } catch (final ParseException ex) {
            return null;
        }
    }

 /**
     * Enable cloud job.
     *
     * @param jobName job name
     * @throws JSONException parse json exception
     */
    @DELETE
    @Path("/{jobName}/disable")
    public void enable(@PathParam("jobName") final String jobName) throws JSONException {
        Optional<CloudJobConfiguration> configOptional = configService.load(jobName);
        if (configOptional.isPresent()) {
            facadeService.enableJob(jobName);
            producerManager.reschedule(jobName);
        }
    }

[ERROR]` 2018-07-17 02:47:28,016 --task-launch-processor RUNNING-- [io.elasticjob.cloud.scheduler.mesos.TaskLaunchScheduledService] Launch task error 
java.lang.IllegalStateException: null
	at com.google.common.base.Preconditions.checkState(Preconditions.java:158) ~[guava-18.0.jar:na]
	at io.elasticjob.cloud.scheduler.mesos.MesosStateService.fetch(MesosStateService.java:138) ~[elastic-job-cloud-scheduler-3.0.0.M1-SNAPSHOT.jar:na]
	at io.elasticjob.cloud.scheduler.mesos.MesosStateService.executors(MesosStateService.java:115) ~[elastic-job-cloud-scheduler-3.0.0.M1-SNAPSHOT.jar:na]
	at io.elasticjob.cloud.scheduler.mesos.MesosStateService.executors(MesosStateService.java:134) ~[elastic-job-cloud-scheduler-3.0.0.M1-SNAPSHOT.jar:na]
	at io.elasticjob.cloud.scheduler.mesos.FacadeService.loadExecutorInfo(FacadeService.java:337) ~[elastic-job-cloud-scheduler-3.0.0.M1-SNAPSHOT.jar:na]
	at io.elasticjob.cloud.scheduler.mesos.AppConstraintEvaluator.loadAppRunningState(AppConstraintEvaluator.java:77) ~[elastic-job-cloud-scheduler-3.0.0.M1-SNAPSHOT.jar:na]
	at io.elasticjob.cloud.scheduler.mesos.TaskLaunchScheduledService.runOneIteration(TaskLaunchScheduledService.java:109) ~[elastic-job-cloud-scheduler-3.0.0.M1-SNAPSHOT.jar:na]
	at com.google.common.util.concurrent.AbstractScheduledService$1$1.run(AbstractScheduledService.java:174) [guava-18.0.jar:na]
	at com.google.common.util.concurrent.Callables$3.run(Callables.java:95) [guava-18.0.jar:na]
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) [na:1.8.0_71]
	at java.util.concurrent.FutureTask.runAndReset(FutureTask.java:308) [na:1.8.0_71]
	at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$301(ScheduledThreadPoolExecutor.java:180) [na:1.8.0_71]
	at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:294) [na:1.8.0_71]
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142) [na:1.8.0_71]
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617) [na:1.8.0_71]
	at java.lang.Thread.run(Thread.java:745) [na:1.8.0_71]