Fixed #160.

apache · Nov 10, 2016 · 75f0da1 · 75f0da1
1 parent af127ef
commit 75f0da1
Show file tree

Hide file tree

Showing 162 changed files with 116 additions and 37 deletions.
diff --git a/...-scheduler/src/main/java/com/dangdang/ddframe/job/cloud/scheduler/context/JobContext.java b/...-scheduler/src/main/java/com/dangdang/ddframe/job/cloud/scheduler/context/JobContext.java
@@ -18,6 +18,7 @@
 package com.dangdang.ddframe.job.cloud.scheduler.context;
 
 import com.dangdang.ddframe.job.cloud.scheduler.config.CloudJobConfiguration;
+import com.dangdang.ddframe.job.context.ExecutionType;
 import lombok.Getter;
 import lombok.RequiredArgsConstructor;
 

diff --git a/...er/src/main/java/com/dangdang/ddframe/job/cloud/scheduler/lifecycle/LifecycleService.java b/...er/src/main/java/com/dangdang/ddframe/job/cloud/scheduler/lifecycle/LifecycleService.java
@@ -17,7 +17,7 @@
 
 package com.dangdang.ddframe.job.cloud.scheduler.lifecycle;
 
-import com.dangdang.ddframe.job.cloud.scheduler.context.TaskContext;
+import com.dangdang.ddframe.job.context.TaskContext;
 import com.dangdang.ddframe.job.cloud.scheduler.state.running.RunningService;
 import org.apache.mesos.Protos;
 import org.apache.mesos.SchedulerDriver;

diff --git a/...scheduler/src/main/java/com/dangdang/ddframe/job/cloud/scheduler/mesos/FacadeService.java b/...scheduler/src/main/java/com/dangdang/ddframe/job/cloud/scheduler/mesos/FacadeService.java
@@ -19,9 +19,9 @@
 
 import com.dangdang.ddframe.job.cloud.scheduler.config.CloudJobConfiguration;
 import com.dangdang.ddframe.job.cloud.scheduler.config.ConfigurationService;
-import com.dangdang.ddframe.job.cloud.scheduler.context.ExecutionType;
+import com.dangdang.ddframe.job.context.ExecutionType;
 import com.dangdang.ddframe.job.cloud.scheduler.context.JobContext;
-import com.dangdang.ddframe.job.cloud.scheduler.context.TaskContext;
+import com.dangdang.ddframe.job.context.TaskContext;
 import com.dangdang.ddframe.job.cloud.scheduler.state.failover.FailoverService;
 import com.dangdang.ddframe.job.cloud.scheduler.state.ready.ReadyService;
 import com.dangdang.ddframe.job.cloud.scheduler.state.running.RunningService;

diff --git a/...cheduler/src/main/java/com/dangdang/ddframe/job/cloud/scheduler/mesos/JobTaskRequest.java b/...cheduler/src/main/java/com/dangdang/ddframe/job/cloud/scheduler/mesos/JobTaskRequest.java
@@ -18,7 +18,7 @@
 package com.dangdang.ddframe.job.cloud.scheduler.mesos;
 
 import com.dangdang.ddframe.job.cloud.scheduler.config.CloudJobConfiguration;
-import com.dangdang.ddframe.job.cloud.scheduler.context.TaskContext;
+import com.dangdang.ddframe.job.context.TaskContext;
 import com.netflix.fenzo.ConstraintEvaluator;
 import com.netflix.fenzo.TaskRequest;
 import com.netflix.fenzo.VMTaskFitnessCalculator;

diff --git a/...cheduler/src/main/java/com/dangdang/ddframe/job/cloud/scheduler/mesos/LaunchingTasks.java b/...cheduler/src/main/java/com/dangdang/ddframe/job/cloud/scheduler/mesos/LaunchingTasks.java
@@ -17,9 +17,9 @@
 
 package com.dangdang.ddframe.job.cloud.scheduler.mesos;
 
-import com.dangdang.ddframe.job.cloud.scheduler.context.ExecutionType;
+import com.dangdang.ddframe.job.context.ExecutionType;
 import com.dangdang.ddframe.job.cloud.scheduler.context.JobContext;
-import com.dangdang.ddframe.job.cloud.scheduler.context.TaskContext;
+import com.dangdang.ddframe.job.context.TaskContext;
 import com.netflix.fenzo.TaskAssignmentResult;
 import com.netflix.fenzo.TaskRequest;
 import com.netflix.fenzo.VMAssignmentResult;

diff --git a/...heduler/src/main/java/com/dangdang/ddframe/job/cloud/scheduler/mesos/SchedulerEngine.java b/...heduler/src/main/java/com/dangdang/ddframe/job/cloud/scheduler/mesos/SchedulerEngine.java
@@ -17,7 +17,7 @@
 
 package com.dangdang.ddframe.job.cloud.scheduler.mesos;
 
-import com.dangdang.ddframe.job.cloud.scheduler.context.TaskContext;
+import com.dangdang.ddframe.job.context.TaskContext;
 import com.dangdang.ddframe.job.event.JobEventBus;
 import com.dangdang.ddframe.job.event.type.JobStatusTraceEvent;
 import com.dangdang.ddframe.job.event.type.JobStatusTraceEvent.Source;

diff --git a/...ler/src/main/java/com/dangdang/ddframe/job/cloud/scheduler/mesos/TaskLaunchProcessor.java b/...ler/src/main/java/com/dangdang/ddframe/job/cloud/scheduler/mesos/TaskLaunchProcessor.java
@@ -19,7 +19,7 @@
 
 import com.dangdang.ddframe.job.cloud.scheduler.boot.env.BootstrapEnvironment;
 import com.dangdang.ddframe.job.cloud.scheduler.config.CloudJobConfiguration;
-import com.dangdang.ddframe.job.cloud.scheduler.context.TaskContext;
+import com.dangdang.ddframe.job.context.TaskContext;
 import com.dangdang.ddframe.job.event.JobEventBus;
 import com.dangdang.ddframe.job.event.type.JobStatusTraceEvent;
 import com.dangdang.ddframe.job.event.type.JobStatusTraceEvent.Source;

diff --git a/...r/src/main/java/com/dangdang/ddframe/job/cloud/scheduler/state/failover/FailoverNode.java b/...r/src/main/java/com/dangdang/ddframe/job/cloud/scheduler/state/failover/FailoverNode.java
@@ -17,7 +17,7 @@
 
 package com.dangdang.ddframe.job.cloud.scheduler.state.failover;
 
-import com.dangdang.ddframe.job.cloud.scheduler.context.TaskContext;
+import com.dangdang.ddframe.job.context.TaskContext;
 import com.dangdang.ddframe.job.cloud.scheduler.state.StateNode;
 import lombok.AccessLevel;
 import lombok.NoArgsConstructor;

diff --git a/...rc/main/java/com/dangdang/ddframe/job/cloud/scheduler/state/failover/FailoverService.java b/...rc/main/java/com/dangdang/ddframe/job/cloud/scheduler/state/failover/FailoverService.java
@@ -21,9 +21,9 @@
 import com.dangdang.ddframe.job.cloud.scheduler.config.CloudJobConfiguration;
 import com.dangdang.ddframe.job.cloud.scheduler.config.ConfigurationService;
 import com.dangdang.ddframe.job.cloud.scheduler.config.JobExecutionType;
-import com.dangdang.ddframe.job.cloud.scheduler.context.ExecutionType;
+import com.dangdang.ddframe.job.context.ExecutionType;
 import com.dangdang.ddframe.job.cloud.scheduler.context.JobContext;
-import com.dangdang.ddframe.job.cloud.scheduler.context.TaskContext;
+import com.dangdang.ddframe.job.context.TaskContext;
 import com.dangdang.ddframe.job.cloud.scheduler.state.running.RunningService;
 import com.dangdang.ddframe.job.reg.base.CoordinatorRegistryCenter;
 import com.google.common.base.Charsets;

diff --git a/...uler/src/main/java/com/dangdang/ddframe/job/cloud/scheduler/state/ready/ReadyService.java b/...uler/src/main/java/com/dangdang/ddframe/job/cloud/scheduler/state/ready/ReadyService.java
@@ -21,7 +21,7 @@
 import com.dangdang.ddframe.job.cloud.scheduler.config.CloudJobConfiguration;
 import com.dangdang.ddframe.job.cloud.scheduler.config.ConfigurationService;
 import com.dangdang.ddframe.job.cloud.scheduler.config.JobExecutionType;
-import com.dangdang.ddframe.job.cloud.scheduler.context.ExecutionType;
+import com.dangdang.ddframe.job.context.ExecutionType;
 import com.dangdang.ddframe.job.cloud.scheduler.context.JobContext;
 import com.dangdang.ddframe.job.cloud.scheduler.state.running.RunningService;
 import com.dangdang.ddframe.job.reg.base.CoordinatorRegistryCenter;

diff --git a/.../src/main/java/com/dangdang/ddframe/job/cloud/scheduler/state/running/RunningService.java b/.../src/main/java/com/dangdang/ddframe/job/cloud/scheduler/state/running/RunningService.java
@@ -17,7 +17,7 @@
 
 package com.dangdang.ddframe.job.cloud.scheduler.state.running;
 
-import com.dangdang.ddframe.job.cloud.scheduler.context.TaskContext;
+import com.dangdang.ddframe.job.context.TaskContext;
 import lombok.Getter;
 
 import java.util.Collection;

diff --git a/...duler/src/test/java/com/dangdang/ddframe/job/cloud/scheduler/context/AllContextTests.java b/...duler/src/test/java/com/dangdang/ddframe/job/cloud/scheduler/context/AllContextTests.java
@@ -22,8 +22,7 @@
 
 @RunWith(Suite.class)
 @Suite.SuiteClasses({
-        JobContextTest.class, 
-        TaskContextTest.class
+        JobContextTest.class
     })
 public final class AllContextTests {
 }
diff --git a/...eduler/src/test/java/com/dangdang/ddframe/job/cloud/scheduler/context/JobContextTest.java b/...eduler/src/test/java/com/dangdang/ddframe/job/cloud/scheduler/context/JobContextTest.java
@@ -19,6 +19,7 @@
 
 import com.dangdang.ddframe.job.cloud.scheduler.config.CloudJobConfiguration;
 import com.dangdang.ddframe.job.cloud.scheduler.fixture.CloudJobConfigurationBuilder;
+import com.dangdang.ddframe.job.context.ExecutionType;
 import org.junit.Test;
 
 import static org.hamcrest.core.Is.is;

diff --git a/...ud-scheduler/src/test/java/com/dangdang/ddframe/job/cloud/scheduler/fixture/TaskNode.java b/...ud-scheduler/src/test/java/com/dangdang/ddframe/job/cloud/scheduler/fixture/TaskNode.java
@@ -17,7 +17,7 @@
 
 package com.dangdang.ddframe.job.cloud.scheduler.fixture;
 
-import com.dangdang.ddframe.job.cloud.scheduler.context.ExecutionType;
+import com.dangdang.ddframe.job.context.ExecutionType;
 import com.google.common.base.Joiner;
 import lombok.Builder;
 

diff --git a/...rc/test/java/com/dangdang/ddframe/job/cloud/scheduler/lifecycle/LifecycleServiceTest.java b/...rc/test/java/com/dangdang/ddframe/job/cloud/scheduler/lifecycle/LifecycleServiceTest.java
@@ -17,7 +17,7 @@
 
 package com.dangdang.ddframe.job.cloud.scheduler.lifecycle;
 
-import com.dangdang.ddframe.job.cloud.scheduler.context.TaskContext;
+import com.dangdang.ddframe.job.context.TaskContext;
 import com.dangdang.ddframe.job.cloud.scheduler.fixture.TaskNode;
 import com.dangdang.ddframe.job.cloud.scheduler.state.running.RunningService;
 import org.apache.mesos.Protos;

diff --git a/...duler/src/test/java/com/dangdang/ddframe/job/cloud/scheduler/mesos/FacadeServiceTest.java b/...duler/src/test/java/com/dangdang/ddframe/job/cloud/scheduler/mesos/FacadeServiceTest.java
@@ -19,9 +19,9 @@
 
 import com.dangdang.ddframe.job.cloud.scheduler.config.CloudJobConfiguration;
 import com.dangdang.ddframe.job.cloud.scheduler.config.ConfigurationService;
-import com.dangdang.ddframe.job.cloud.scheduler.context.ExecutionType;
+import com.dangdang.ddframe.job.context.ExecutionType;
 import com.dangdang.ddframe.job.cloud.scheduler.context.JobContext;
-import com.dangdang.ddframe.job.cloud.scheduler.context.TaskContext;
+import com.dangdang.ddframe.job.context.TaskContext;
 import com.dangdang.ddframe.job.cloud.scheduler.fixture.CloudJobConfigurationBuilder;
 import com.dangdang.ddframe.job.cloud.scheduler.fixture.TaskNode;
 import com.dangdang.ddframe.job.cloud.scheduler.state.failover.FailoverService;

diff --git a/...uler/src/test/java/com/dangdang/ddframe/job/cloud/scheduler/mesos/JobTaskRequestTest.java b/...uler/src/test/java/com/dangdang/ddframe/job/cloud/scheduler/mesos/JobTaskRequestTest.java
@@ -17,8 +17,8 @@
 
 package com.dangdang.ddframe.job.cloud.scheduler.mesos;
 
-import com.dangdang.ddframe.job.cloud.scheduler.context.ExecutionType;
-import com.dangdang.ddframe.job.cloud.scheduler.context.TaskContext;
+import com.dangdang.ddframe.job.context.ExecutionType;
+import com.dangdang.ddframe.job.context.TaskContext;
 import com.dangdang.ddframe.job.cloud.scheduler.fixture.CloudJobConfigurationBuilder;
 import com.netflix.fenzo.TaskRequest;
 import org.junit.Test;

diff --git a/...uler/src/test/java/com/dangdang/ddframe/job/cloud/scheduler/mesos/LaunchingTasksTest.java b/...uler/src/test/java/com/dangdang/ddframe/job/cloud/scheduler/mesos/LaunchingTasksTest.java
@@ -17,7 +17,7 @@
 
 package com.dangdang.ddframe.job.cloud.scheduler.mesos;
 
-import com.dangdang.ddframe.job.cloud.scheduler.context.ExecutionType;
+import com.dangdang.ddframe.job.context.ExecutionType;
 import com.dangdang.ddframe.job.cloud.scheduler.context.JobContext;
 import com.dangdang.ddframe.job.cloud.scheduler.fixture.CloudJobConfigurationBuilder;
 import com.netflix.fenzo.TaskRequest;

diff --git a/...ler/src/test/java/com/dangdang/ddframe/job/cloud/scheduler/mesos/SchedulerEngineTest.java b/...ler/src/test/java/com/dangdang/ddframe/job/cloud/scheduler/mesos/SchedulerEngineTest.java
@@ -17,9 +17,9 @@
 
 package com.dangdang.ddframe.job.cloud.scheduler.mesos;
 
-import com.dangdang.ddframe.job.cloud.scheduler.context.ExecutionType;
+import com.dangdang.ddframe.job.context.ExecutionType;
 import com.dangdang.ddframe.job.cloud.scheduler.context.JobContext;
-import com.dangdang.ddframe.job.cloud.scheduler.context.TaskContext;
+import com.dangdang.ddframe.job.context.TaskContext;
 import com.dangdang.ddframe.job.cloud.scheduler.fixture.CloudJobConfigurationBuilder;
 import com.dangdang.ddframe.job.cloud.scheduler.fixture.TaskNode;
 import com.dangdang.ddframe.job.cloud.scheduler.mesos.fixture.OfferBuilder;

diff --git a/.../src/test/java/com/dangdang/ddframe/job/cloud/scheduler/producer/ProducerManagerTest.java b/.../src/test/java/com/dangdang/ddframe/job/cloud/scheduler/producer/ProducerManagerTest.java
@@ -20,7 +20,7 @@
 import com.dangdang.ddframe.job.cloud.scheduler.config.CloudJobConfiguration;
 import com.dangdang.ddframe.job.cloud.scheduler.config.ConfigurationService;
 import com.dangdang.ddframe.job.cloud.scheduler.config.JobExecutionType;
-import com.dangdang.ddframe.job.cloud.scheduler.context.TaskContext;
+import com.dangdang.ddframe.job.context.TaskContext;
 import com.dangdang.ddframe.job.cloud.scheduler.fixture.CloudJobConfigurationBuilder;
 import com.dangdang.ddframe.job.cloud.scheduler.lifecycle.LifecycleService;
 import com.dangdang.ddframe.job.cloud.scheduler.state.ready.ReadyService;

diff --git a/...c/test/java/com/dangdang/ddframe/job/cloud/scheduler/state/failover/FailoverNodeTest.java b/...c/test/java/com/dangdang/ddframe/job/cloud/scheduler/state/failover/FailoverNodeTest.java
@@ -17,7 +17,7 @@
 
 package com.dangdang.ddframe.job.cloud.scheduler.state.failover;
 
-import com.dangdang.ddframe.job.cloud.scheduler.context.ExecutionType;
+import com.dangdang.ddframe.job.context.ExecutionType;
 import com.dangdang.ddframe.job.cloud.scheduler.fixture.TaskNode;
 import org.junit.Test;
 

diff --git a/...est/java/com/dangdang/ddframe/job/cloud/scheduler/state/failover/FailoverServiceTest.java b/...est/java/com/dangdang/ddframe/job/cloud/scheduler/state/failover/FailoverServiceTest.java
@@ -21,9 +21,9 @@
 import com.dangdang.ddframe.job.cloud.scheduler.config.CloudJobConfiguration;
 import com.dangdang.ddframe.job.cloud.scheduler.config.ConfigurationService;
 import com.dangdang.ddframe.job.cloud.scheduler.config.JobExecutionType;
-import com.dangdang.ddframe.job.cloud.scheduler.context.ExecutionType;
+import com.dangdang.ddframe.job.context.ExecutionType;
 import com.dangdang.ddframe.job.cloud.scheduler.context.JobContext;
-import com.dangdang.ddframe.job.cloud.scheduler.context.TaskContext;
+import com.dangdang.ddframe.job.context.TaskContext;
 import com.dangdang.ddframe.job.cloud.scheduler.fixture.CloudJobConfigurationBuilder;
 import com.dangdang.ddframe.job.cloud.scheduler.fixture.TaskNode;
 import com.dangdang.ddframe.job.cloud.scheduler.state.running.RunningService;

diff --git a/.../src/test/java/com/dangdang/ddframe/job/cloud/scheduler/state/ready/ReadyServiceTest.java b/.../src/test/java/com/dangdang/ddframe/job/cloud/scheduler/state/ready/ReadyServiceTest.java
@@ -21,7 +21,7 @@
 import com.dangdang.ddframe.job.cloud.scheduler.config.CloudJobConfiguration;
 import com.dangdang.ddframe.job.cloud.scheduler.config.ConfigurationService;
 import com.dangdang.ddframe.job.cloud.scheduler.config.JobExecutionType;
-import com.dangdang.ddframe.job.cloud.scheduler.context.ExecutionType;
+import com.dangdang.ddframe.job.context.ExecutionType;
 import com.dangdang.ddframe.job.cloud.scheduler.context.JobContext;
 import com.dangdang.ddframe.job.cloud.scheduler.fixture.CloudJobConfigurationBuilder;
 import com.dangdang.ddframe.job.cloud.scheduler.state.running.RunningService;

diff --git a/.../test/java/com/dangdang/ddframe/job/cloud/scheduler/state/running/RunningServiceTest.java b/.../test/java/com/dangdang/ddframe/job/cloud/scheduler/state/running/RunningServiceTest.java
@@ -17,7 +17,7 @@
 
 package com.dangdang.ddframe.job.cloud.scheduler.state.running;
 
-import com.dangdang.ddframe.job.cloud.scheduler.context.TaskContext;
+import com.dangdang.ddframe.job.context.TaskContext;
 import com.dangdang.ddframe.job.cloud.scheduler.fixture.TaskNode;
 import org.junit.After;
 import org.junit.Before;

diff --git a/elastic-job-common/elastic-job-core/pom.xml → ...ob-common/elastic-job-common-core/pom.xml b/elastic-job-common/elastic-job-core/pom.xml → ...ob-common/elastic-job-common-core/pom.xml
@@ -6,7 +6,7 @@
         <artifactId>elastic-job-common</artifactId>
         <version>2.0.2-SNAPSHOT</version>
     </parent>
-    <artifactId>elastic-job-core</artifactId>
+    <artifactId>elastic-job-common-core</artifactId>
     <name>${project.artifactId}</name>
 
     <dependencies>

diff --git a/.../dangdang/ddframe/job/api/ElasticJob.java → .../dangdang/ddframe/job/api/ElasticJob.java b/.../dangdang/ddframe/job/api/ElasticJob.java → .../dangdang/ddframe/job/api/ElasticJob.java
diff --git a/...com/dangdang/ddframe/job/api/JobType.java → ...com/dangdang/ddframe/job/api/JobType.java b/...com/dangdang/ddframe/job/api/JobType.java → ...com/dangdang/ddframe/job/api/JobType.java
diff --git a/...dang/ddframe/job/api/ShardingContext.java → ...dang/ddframe/job/api/ShardingContext.java b/...dang/ddframe/job/api/ShardingContext.java → ...dang/ddframe/job/api/ShardingContext.java
diff --git a/...ddframe/job/api/dataflow/DataflowJob.java → ...ddframe/job/api/dataflow/DataflowJob.java b/...ddframe/job/api/dataflow/DataflowJob.java → ...ddframe/job/api/dataflow/DataflowJob.java
diff --git a/...ang/ddframe/job/api/script/ScriptJob.java → ...ang/ddframe/job/api/script/ScriptJob.java b/...ang/ddframe/job/api/script/ScriptJob.java → ...ang/ddframe/job/api/script/ScriptJob.java
diff --git a/...ang/ddframe/job/api/simple/SimpleJob.java → ...ang/ddframe/job/api/simple/SimpleJob.java b/...ang/ddframe/job/api/simple/SimpleJob.java → ...ang/ddframe/job/api/simple/SimpleJob.java
diff --git a/...rame/job/config/JobCoreConfiguration.java → ...rame/job/config/JobCoreConfiguration.java b/...rame/job/config/JobCoreConfiguration.java → ...rame/job/config/JobCoreConfiguration.java
diff --git a/...rame/job/config/JobRootConfiguration.java → ...rame/job/config/JobRootConfiguration.java b/...rame/job/config/JobRootConfiguration.java → ...rame/job/config/JobRootConfiguration.java
diff --git a/...rame/job/config/JobTypeConfiguration.java → ...rame/job/config/JobTypeConfiguration.java b/...rame/job/config/JobTypeConfiguration.java → ...rame/job/config/JobTypeConfiguration.java
diff --git a/...ig/dataflow/DataflowJobConfiguration.java → ...ig/dataflow/DataflowJobConfiguration.java b/...ig/dataflow/DataflowJobConfiguration.java → ...ig/dataflow/DataflowJobConfiguration.java
diff --git a/...config/script/ScriptJobConfiguration.java → ...config/script/ScriptJobConfiguration.java b/...config/script/ScriptJobConfiguration.java → ...config/script/ScriptJobConfiguration.java
diff --git a/...config/simple/SimpleJobConfiguration.java → ...config/simple/SimpleJobConfiguration.java b/...config/simple/SimpleJobConfiguration.java → ...config/simple/SimpleJobConfiguration.java
diff --git a/...loud/scheduler/context/ExecutionType.java → ...ng/ddframe/job/context/ExecutionType.java b/...loud/scheduler/context/ExecutionType.java → ...ng/ddframe/job/context/ExecutionType.java
@@ -15,7 +15,7 @@
  * </p>
  */
 
-package com.dangdang.ddframe.job.cloud.scheduler.context;
+package com.dangdang.ddframe.job.context;
 
 /**
  * 执行类型.

diff --git a/.../cloud/scheduler/context/TaskContext.java → ...dang/ddframe/job/context/TaskContext.java b/.../cloud/scheduler/context/TaskContext.java → ...dang/ddframe/job/context/TaskContext.java
@@ -15,7 +15,7 @@
  * </p>
  */
 
-package com.dangdang.ddframe.job.cloud.scheduler.context;
+package com.dangdang.ddframe.job.context;
 
 import com.dangdang.ddframe.job.util.digest.Encryption;
 import com.google.common.base.Joiner;

diff --git a/.../dangdang/ddframe/job/event/JobEvent.java → .../dangdang/ddframe/job/event/JobEvent.java b/.../dangdang/ddframe/job/event/JobEvent.java → .../dangdang/ddframe/job/event/JobEvent.java
diff --git a/...ngdang/ddframe/job/event/JobEventBus.java → ...ngdang/ddframe/job/event/JobEventBus.java b/...ngdang/ddframe/job/event/JobEventBus.java → ...ngdang/ddframe/job/event/JobEventBus.java
diff --git a/...rame/job/event/JobEventConfiguration.java → ...rame/job/event/JobEventConfiguration.java b/...rame/job/event/JobEventConfiguration.java → ...rame/job/event/JobEventConfiguration.java
diff --git a/...g/ddframe/job/event/JobEventIdentity.java → ...g/ddframe/job/event/JobEventIdentity.java b/...g/ddframe/job/event/JobEventIdentity.java → ...g/ddframe/job/event/JobEventIdentity.java
diff --git a/...g/ddframe/job/event/JobEventListener.java → ...g/ddframe/job/event/JobEventListener.java b/...g/ddframe/job/event/JobEventListener.java → ...g/ddframe/job/event/JobEventListener.java
diff --git a/...bEventListenerConfigurationException.java → ...bEventListenerConfigurationException.java b/...bEventListenerConfigurationException.java → ...bEventListenerConfigurationException.java
diff --git a/...b/event/rdb/JobEventRdbConfiguration.java → ...b/event/rdb/JobEventRdbConfiguration.java b/...b/event/rdb/JobEventRdbConfiguration.java → ...b/event/rdb/JobEventRdbConfiguration.java
diff --git a/...me/job/event/rdb/JobEventRdbIdentity.java → ...me/job/event/rdb/JobEventRdbIdentity.java b/...me/job/event/rdb/JobEventRdbIdentity.java → ...me/job/event/rdb/JobEventRdbIdentity.java
diff --git a/...me/job/event/rdb/JobEventRdbListener.java → ...me/job/event/rdb/JobEventRdbListener.java b/...me/job/event/rdb/JobEventRdbListener.java → ...me/job/event/rdb/JobEventRdbListener.java
diff --git a/...ame/job/event/rdb/JobEventRdbStorage.java → ...ame/job/event/rdb/JobEventRdbStorage.java b/...ame/job/event/rdb/JobEventRdbStorage.java → ...ame/job/event/rdb/JobEventRdbStorage.java
diff --git a/...ame/job/event/type/JobExecutionEvent.java → ...ame/job/event/type/JobExecutionEvent.java b/...ame/job/event/type/JobExecutionEvent.java → ...ame/job/event/type/JobExecutionEvent.java
diff --git a/...e/job/event/type/JobStatusTraceEvent.java → ...e/job/event/type/JobStatusTraceEvent.java b/...e/job/event/type/JobStatusTraceEvent.java → ...e/job/event/type/JobStatusTraceEvent.java
diff --git a/.../exception/JobConfigurationException.java → .../exception/JobConfigurationException.java b/.../exception/JobConfigurationException.java → .../exception/JobConfigurationException.java
diff --git a/...ion/JobExecutionEnvironmentException.java → ...ion/JobExecutionEnvironmentException.java b/...ion/JobExecutionEnvironmentException.java → ...ion/JobExecutionEnvironmentException.java
diff --git a/...ame/job/exception/JobSystemException.java → ...ame/job/exception/JobSystemException.java b/...ame/job/exception/JobSystemException.java → ...ame/job/exception/JobSystemException.java
diff --git a/.../executor/AbstractElasticJobExecutor.java → .../executor/AbstractElasticJobExecutor.java b/.../executor/AbstractElasticJobExecutor.java → .../executor/AbstractElasticJobExecutor.java
@@ -20,6 +20,7 @@
 import com.dangdang.ddframe.job.api.ShardingContext;
 import com.dangdang.ddframe.job.config.JobRootConfiguration;
 import com.dangdang.ddframe.job.event.type.JobExecutionEvent;
+import com.dangdang.ddframe.job.event.type.JobStatusTraceEvent.State;
 import com.dangdang.ddframe.job.exception.JobExecutionEnvironmentException;
 import com.dangdang.ddframe.job.exception.JobSystemException;
 import com.dangdang.ddframe.job.executor.handler.ExecutorServiceHandler;
@@ -172,16 +173,19 @@ public void run() {
 
     private void process(final ShardingContexts shardingContexts, final int item, final JobExecutionEvent jobExecutionEvent) {
         jobFacade.postJobExecutionEvent(jobExecutionEvent);
+        jobFacade.postJobStatusTraceEvent(jobExecutionEvent.getTaskId(), State.TASK_RUNNING, "");
         log.trace("Job '{}' executing, item is: '{}'.", jobName, item);
         try {
             process(new ShardingContext(shardingContexts, item));
             jobExecutionEvent.executionSuccess();
             log.trace("Job '{}' executed, item is: '{}'.", jobName, item);
+            jobFacade.postJobStatusTraceEvent(jobExecutionEvent.getTaskId(), State.TASK_FINISHED, "");
             // CHECKSTYLE:OFF
         } catch (final Throwable ex) {
             // CHECKSTYLE:ON
             jobExecutionEvent.executionFailure(ex);
             jobExceptionHandler.handleException(jobName, ex);
+            jobFacade.postJobStatusTraceEvent(jobExecutionEvent.getTaskId(), State.TASK_FAILED, "");
         } finally {
             jobFacade.postJobExecutionEvent(jobExecutionEvent);
         }

diff --git a/...rame/job/executor/JobExecutorFactory.java → ...rame/job/executor/JobExecutorFactory.java b/...rame/job/executor/JobExecutorFactory.java → ...rame/job/executor/JobExecutorFactory.java
diff --git a/...gdang/ddframe/job/executor/JobFacade.java → ...gdang/ddframe/job/executor/JobFacade.java b/...gdang/ddframe/job/executor/JobFacade.java → ...gdang/ddframe/job/executor/JobFacade.java
diff --git a/...dframe/job/executor/ShardingContexts.java → ...dframe/job/executor/ShardingContexts.java b/...dframe/job/executor/ShardingContexts.java → ...dframe/job/executor/ShardingContexts.java
diff --git a/...cutor/handler/ExecutorServiceHandler.java → ...cutor/handler/ExecutorServiceHandler.java b/...cutor/handler/ExecutorServiceHandler.java → ...cutor/handler/ExecutorServiceHandler.java
diff --git a/...ndler/ExecutorServiceHandlerRegistry.java → ...ndler/ExecutorServiceHandlerRegistry.java b/...ndler/ExecutorServiceHandlerRegistry.java → ...ndler/ExecutorServiceHandlerRegistry.java
diff --git a/...executor/handler/JobExceptionHandler.java → ...executor/handler/JobExceptionHandler.java b/...executor/handler/JobExceptionHandler.java → ...executor/handler/JobExceptionHandler.java
diff --git a/...e/job/executor/handler/JobProperties.java → ...e/job/executor/handler/JobProperties.java b/...e/job/executor/handler/JobProperties.java → ...e/job/executor/handler/JobProperties.java
diff --git a/...r/impl/DefaultExecutorServiceHandler.java → ...r/impl/DefaultExecutorServiceHandler.java b/...r/impl/DefaultExecutorServiceHandler.java → ...r/impl/DefaultExecutorServiceHandler.java
diff --git a/...dler/impl/DefaultJobExceptionHandler.java → ...dler/impl/DefaultJobExceptionHandler.java b/...dler/impl/DefaultJobExceptionHandler.java → ...dler/impl/DefaultJobExceptionHandler.java
diff --git a/...ob/executor/type/DataflowJobExecutor.java → ...ob/executor/type/DataflowJobExecutor.java b/...ob/executor/type/DataflowJobExecutor.java → ...ob/executor/type/DataflowJobExecutor.java
diff --git a/.../job/executor/type/ScriptJobExecutor.java → .../job/executor/type/ScriptJobExecutor.java b/.../job/executor/type/ScriptJobExecutor.java → .../job/executor/type/ScriptJobExecutor.java
diff --git a/.../job/executor/type/SimpleJobExecutor.java → .../job/executor/type/SimpleJobExecutor.java b/.../job/executor/type/SimpleJobExecutor.java → .../job/executor/type/SimpleJobExecutor.java
diff --git a/...b/reg/base/CoordinatorRegistryCenter.java → ...b/reg/base/CoordinatorRegistryCenter.java b/...b/reg/base/CoordinatorRegistryCenter.java → ...b/reg/base/CoordinatorRegistryCenter.java
diff --git a/.../ddframe/job/reg/base/RegistryCenter.java → .../ddframe/job/reg/base/RegistryCenter.java b/.../ddframe/job/reg/base/RegistryCenter.java → .../ddframe/job/reg/base/RegistryCenter.java
diff --git a/...frame/job/reg/exception/RegException.java → ...frame/job/reg/exception/RegException.java b/...frame/job/reg/exception/RegException.java → ...frame/job/reg/exception/RegException.java
diff --git a/...ob/reg/exception/RegExceptionHandler.java → ...ob/reg/exception/RegExceptionHandler.java b/...ob/reg/exception/RegExceptionHandler.java → ...ob/reg/exception/RegExceptionHandler.java
diff --git a/...reg/zookeeper/ZookeeperConfiguration.java → ...reg/zookeeper/ZookeeperConfiguration.java b/...reg/zookeeper/ZookeeperConfiguration.java → ...reg/zookeeper/ZookeeperConfiguration.java
diff --git a/...eg/zookeeper/ZookeeperRegistryCenter.java → ...eg/zookeeper/ZookeeperRegistryCenter.java b/...eg/zookeeper/ZookeeperRegistryCenter.java → ...eg/zookeeper/ZookeeperRegistryCenter.java
diff --git a/...frame/job/util/concurrent/BlockUtils.java → ...frame/job/util/concurrent/BlockUtils.java b/...frame/job/util/concurrent/BlockUtils.java → ...frame/job/util/concurrent/BlockUtils.java
diff --git a/...til/concurrent/ExecutorServiceObject.java → ...til/concurrent/ExecutorServiceObject.java b/...til/concurrent/ExecutorServiceObject.java → ...til/concurrent/ExecutorServiceObject.java
diff --git a/...b/util/config/ShardingItemParameters.java → ...b/util/config/ShardingItemParameters.java b/...b/util/config/ShardingItemParameters.java → ...b/util/config/ShardingItemParameters.java
diff --git a/...dframe/job/util/config/ShardingItems.java → ...dframe/job/util/config/ShardingItems.java b/...dframe/job/util/config/ShardingItems.java → ...dframe/job/util/config/ShardingItems.java
diff --git a/...g/ddframe/job/util/digest/Encryption.java → ...g/ddframe/job/util/digest/Encryption.java b/...g/ddframe/job/util/digest/Encryption.java → ...g/ddframe/job/util/digest/Encryption.java
diff --git a/...g/ddframe/job/util/env/HostException.java → ...g/ddframe/job/util/env/HostException.java b/...g/ddframe/job/util/env/HostException.java → ...g/ddframe/job/util/env/HostException.java
diff --git a/...dframe/job/util/env/LocalHostService.java → ...dframe/job/util/env/LocalHostService.java b/...dframe/job/util/env/LocalHostService.java → ...dframe/job/util/env/LocalHostService.java
diff --git a/...ang/ddframe/job/util/env/TimeService.java → ...ang/ddframe/job/util/env/TimeService.java b/...ang/ddframe/job/util/env/TimeService.java → ...ang/ddframe/job/util/env/TimeService.java
diff --git a/...tractJobConfigurationGsonTypeAdapter.java → ...tractJobConfigurationGsonTypeAdapter.java b/...tractJobConfigurationGsonTypeAdapter.java → ...tractJobConfigurationGsonTypeAdapter.java
diff --git a/...ng/ddframe/job/util/json/GsonFactory.java → ...ng/ddframe/job/util/json/GsonFactory.java b/...ng/ddframe/job/util/json/GsonFactory.java → ...ng/ddframe/job/util/json/GsonFactory.java
diff --git a/...me/job/util/restful/GsonJsonProvider.java → ...me/job/util/restful/GsonJsonProvider.java b/...me/job/util/restful/GsonJsonProvider.java → ...me/job/util/restful/GsonJsonProvider.java
diff --git a/...me/job/util/restful/RestfulException.java → ...me/job/util/restful/RestfulException.java b/...me/job/util/restful/RestfulException.java → ...me/job/util/restful/RestfulException.java
diff --git a/.../util/restful/RestfulExceptionMapper.java → .../util/restful/RestfulExceptionMapper.java b/.../util/restful/RestfulExceptionMapper.java → .../util/restful/RestfulExceptionMapper.java
diff --git a/...frame/job/util/restful/RestfulServer.java → ...frame/job/util/restful/RestfulServer.java b/...frame/job/util/restful/RestfulServer.java → ...frame/job/util/restful/RestfulServer.java
diff --git a/...om/dangdang/ddframe/job/AllCoreTests.java → ...om/dangdang/ddframe/job/AllCoreTests.java b/...om/dangdang/ddframe/job/AllCoreTests.java → ...om/dangdang/ddframe/job/AllCoreTests.java
diff --git a/...dangdang/ddframe/job/api/AllApiTests.java → ...dangdang/ddframe/job/api/AllApiTests.java b/...dangdang/ddframe/job/api/AllApiTests.java → ...dangdang/ddframe/job/api/AllApiTests.java
diff --git a/.../ddframe/job/api/ShardingContextTest.java → .../ddframe/job/api/ShardingContextTest.java b/.../ddframe/job/api/ShardingContextTest.java → .../ddframe/job/api/ShardingContextTest.java
diff --git a/...ng/ddframe/job/config/AllConfigTests.java → ...ng/ddframe/job/config/AllConfigTests.java b/...ng/ddframe/job/config/AllConfigTests.java → ...ng/ddframe/job/config/AllConfigTests.java
diff --git a/.../job/config/JobCoreConfigurationTest.java → .../job/config/JobCoreConfigurationTest.java b/.../job/config/JobCoreConfigurationTest.java → .../job/config/JobCoreConfigurationTest.java
diff --git a/...astic-job-common-core/src/test/java/com/dangdang/ddframe/job/context/AllContextTests.java b/...astic-job-common-core/src/test/java/com/dangdang/ddframe/job/context/AllContextTests.java
@@ -0,0 +1,28 @@
+/*
+ * Copyright 1999-2015 dangdang.com.
+ * <p>
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ * </p>
+ */
+
+package com.dangdang.ddframe.job.context;
+
+import org.junit.runner.RunWith;
+import org.junit.runners.Suite;
+
+@RunWith(Suite.class)
+@Suite.SuiteClasses({
+        TaskContextTest.class
+})
+public final class AllContextTests {
+}
diff --git a/...ud/scheduler/context/TaskContextTest.java → .../ddframe/job/context/TaskContextTest.java b/...ud/scheduler/context/TaskContextTest.java → .../ddframe/job/context/TaskContextTest.java
@@ -15,9 +15,10 @@
  * </p>
  */
 
-package com.dangdang.ddframe.job.cloud.scheduler.context;
+package com.dangdang.ddframe.job.context;
 
-import com.dangdang.ddframe.job.cloud.scheduler.fixture.TaskNode;
+import com.dangdang.ddframe.job.fixture.context.TaskNode;
+import org.hamcrest.core.Is;
 import org.junit.Test;
 
 import static org.hamcrest.core.Is.is;
@@ -45,7 +46,7 @@ public void assertGetMetaInfo() {
     @Test
     public void assertTaskContextFrom() {
         TaskContext actual = TaskContext.from(TaskNode.builder().build().getTaskNodeValue());
-        assertThat(actual.getId(), is(TaskNode.builder().build().getTaskNodeValue()));
+        assertThat(actual.getId(), Is.is(TaskNode.builder().build().getTaskNodeValue()));
         assertThat(actual.getMetaInfo().getJobName(), is("test_job"));
         assertThat(actual.getMetaInfo().getShardingItem(), is(0));
         assertThat(actual.getType(), is(ExecutionType.READY));

diff --git a/...dang/ddframe/job/event/AllEventTests.java → ...dang/ddframe/job/event/AllEventTests.java b/...dang/ddframe/job/event/AllEventTests.java → ...dang/ddframe/job/event/AllEventTests.java
diff --git a/...ng/ddframe/job/event/JobEventBusTest.java → ...ng/ddframe/job/event/JobEventBusTest.java b/...ng/ddframe/job/event/JobEventBusTest.java → ...ng/ddframe/job/event/JobEventBusTest.java
diff --git a/...rame/job/event/JobExecutionEventTest.java → ...rame/job/event/JobExecutionEventTest.java b/...rame/job/event/JobExecutionEventTest.java → ...rame/job/event/JobExecutionEventTest.java
diff --git a/...ame/job/event/fixture/JobEventCaller.java → ...ame/job/event/fixture/JobEventCaller.java b/...ame/job/event/fixture/JobEventCaller.java → ...ame/job/event/fixture/JobEventCaller.java
diff --git a/...nt/fixture/TestJobEventConfiguration.java → ...nt/fixture/TestJobEventConfiguration.java b/...nt/fixture/TestJobEventConfiguration.java → ...nt/fixture/TestJobEventConfiguration.java
diff --git a/...ure/TestJobEventFailureConfiguration.java → ...ure/TestJobEventFailureConfiguration.java b/...ure/TestJobEventFailureConfiguration.java → ...ure/TestJobEventFailureConfiguration.java
diff --git a/...b/event/fixture/TestJobEventIdentity.java → ...b/event/fixture/TestJobEventIdentity.java b/...b/event/fixture/TestJobEventIdentity.java → ...b/event/fixture/TestJobEventIdentity.java
diff --git a/...b/event/fixture/TestJobEventListener.java → ...b/event/fixture/TestJobEventListener.java b/...b/event/fixture/TestJobEventListener.java → ...b/event/fixture/TestJobEventListener.java
diff --git a/...ent/rdb/JobEventRdbConfigurationTest.java → ...ent/rdb/JobEventRdbConfigurationTest.java b/...ent/rdb/JobEventRdbConfigurationTest.java → ...ent/rdb/JobEventRdbConfigurationTest.java
diff --git a/...ob/event/rdb/JobEventRdbIdentityTest.java → ...ob/event/rdb/JobEventRdbIdentityTest.java b/...ob/event/rdb/JobEventRdbIdentityTest.java → ...ob/event/rdb/JobEventRdbIdentityTest.java
diff --git a/...ob/event/rdb/JobEventRdbListenerTest.java → ...ob/event/rdb/JobEventRdbListenerTest.java b/...ob/event/rdb/JobEventRdbListenerTest.java → ...ob/event/rdb/JobEventRdbListenerTest.java
diff --git a/...job/event/rdb/JobEventRdbStorageTest.java → ...job/event/rdb/JobEventRdbStorageTest.java b/...job/event/rdb/JobEventRdbStorageTest.java → ...job/event/rdb/JobEventRdbStorageTest.java
diff --git a/...rame/job/exception/AllExceptionTests.java → ...rame/job/exception/AllExceptionTests.java b/...rame/job/exception/AllExceptionTests.java → ...rame/job/exception/AllExceptionTests.java
diff --git a/...eption/JobConfigurationExceptionTest.java → ...eption/JobConfigurationExceptionTest.java b/...eption/JobConfigurationExceptionTest.java → ...eption/JobConfigurationExceptionTest.java
diff --git a/...JobExecutionEnvironmentExceptionTest.java → ...JobExecutionEnvironmentExceptionTest.java b/...JobExecutionEnvironmentExceptionTest.java → ...JobExecutionEnvironmentExceptionTest.java
diff --git a/...job/exception/JobSystemExceptionTest.java → ...job/exception/JobSystemExceptionTest.java b/...job/exception/JobSystemExceptionTest.java → ...job/exception/JobSystemExceptionTest.java
diff --git a/...dframe/job/executor/AllExecutorTests.java → ...dframe/job/executor/AllExecutorTests.java b/...dframe/job/executor/AllExecutorTests.java → ...dframe/job/executor/AllExecutorTests.java
diff --git a/.../job/executor/JobExecutorFactoryTest.java → .../job/executor/JobExecutorFactoryTest.java b/.../job/executor/JobExecutorFactoryTest.java → .../job/executor/JobExecutorFactoryTest.java
diff --git a/...r/ExecutorServiceHandlerRegistryTest.java → ...r/ExecutorServiceHandlerRegistryTest.java b/...r/ExecutorServiceHandlerRegistryTest.java → ...r/ExecutorServiceHandlerRegistryTest.java
diff --git a/...b/executor/handler/JobPropertiesTest.java → ...b/executor/handler/JobPropertiesTest.java b/...b/executor/handler/JobPropertiesTest.java → ...b/executor/handler/JobPropertiesTest.java
diff --git a/.../impl/DefaultJobExceptionHandlerTest.java → .../impl/DefaultJobExceptionHandlerTest.java b/.../impl/DefaultJobExceptionHandlerTest.java → .../impl/DefaultJobExceptionHandlerTest.java
diff --git a/...xecutor/type/DataflowJobExecutorTest.java → ...xecutor/type/DataflowJobExecutorTest.java b/...xecutor/type/DataflowJobExecutorTest.java → ...xecutor/type/DataflowJobExecutorTest.java
diff --git a/...e/job/executor/type/ElasticJobVerify.java → ...e/job/executor/type/ElasticJobVerify.java b/...e/job/executor/type/ElasticJobVerify.java → ...e/job/executor/type/ElasticJobVerify.java
diff --git a/.../executor/type/ScriptJobExecutorTest.java → .../executor/type/ScriptJobExecutorTest.java b/.../executor/type/ScriptJobExecutorTest.java → .../executor/type/ScriptJobExecutorTest.java
diff --git a/.../executor/type/SimpleJobExecutorTest.java → .../executor/type/SimpleJobExecutorTest.java b/.../executor/type/SimpleJobExecutorTest.java → .../executor/type/SimpleJobExecutorTest.java
diff --git a/...ddframe/job/fixture/APIJsonConstants.java → ...ddframe/job/fixture/APIJsonConstants.java b/...ddframe/job/fixture/APIJsonConstants.java → ...ddframe/job/fixture/APIJsonConstants.java
diff --git a/.../job/fixture/ShardingContextsBuilder.java → .../job/fixture/ShardingContextsBuilder.java b/.../job/fixture/ShardingContextsBuilder.java → .../job/fixture/ShardingContextsBuilder.java
diff --git a/.../config/TestDataflowJobConfiguration.java → .../config/TestDataflowJobConfiguration.java b/.../config/TestDataflowJobConfiguration.java → .../config/TestDataflowJobConfiguration.java
diff --git a/...ture/config/TestJobRootConfiguration.java → ...ture/config/TestJobRootConfiguration.java b/...ture/config/TestJobRootConfiguration.java → ...ture/config/TestJobRootConfiguration.java
diff --git a/...re/config/TestScriptJobConfiguration.java → ...re/config/TestScriptJobConfiguration.java b/...re/config/TestScriptJobConfiguration.java → ...re/config/TestScriptJobConfiguration.java
diff --git a/...re/config/TestSimpleJobConfiguration.java → ...re/config/TestSimpleJobConfiguration.java b/...re/config/TestSimpleJobConfiguration.java → ...re/config/TestSimpleJobConfiguration.java
diff --git a/...stic-job-common-core/src/test/java/com/dangdang/ddframe/job/fixture/context/TaskNode.java b/...stic-job-common-core/src/test/java/com/dangdang/ddframe/job/fixture/context/TaskNode.java
@@ -0,0 +1,44 @@
+/*
+ * Copyright 1999-2015 dangdang.com.
+ * <p>
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ * </p>
+ */
+
+package com.dangdang.ddframe.job.fixture.context;
+
+import com.dangdang.ddframe.job.context.ExecutionType;
+import com.google.common.base.Joiner;
+import lombok.Builder;
+
+@Builder
+public final class TaskNode {
+
+    private String jobName;
+
+    private int shardingItem;
+
+    private ExecutionType type;
+
+    private String slaveId;
+
+    private String uuid;
+
+    public String getTaskNodePath() {
+        return Joiner.on("@-@").join(null == jobName ? "test_job" : jobName, shardingItem);
+    }
+
+    public String getTaskNodeValue() {
+        return Joiner.on("@-@").join(getTaskNodePath(), null == type ? ExecutionType.READY : type, null == slaveId ? "slave-S0" : slaveId, null == uuid ? "0" : uuid);
+    }
+}
diff --git a/...re/handler/IgnoreJobExceptionHandler.java → ...re/handler/IgnoreJobExceptionHandler.java b/...re/handler/IgnoreJobExceptionHandler.java → ...re/handler/IgnoreJobExceptionHandler.java
diff --git a/...ure/handler/ThrowJobExceptionHandler.java → ...ure/handler/ThrowJobExceptionHandler.java b/...ure/handler/ThrowJobExceptionHandler.java → ...ure/handler/ThrowJobExceptionHandler.java
diff --git a/...ng/ddframe/job/fixture/job/JobCaller.java → ...ng/ddframe/job/fixture/job/JobCaller.java b/...ng/ddframe/job/fixture/job/JobCaller.java → ...ng/ddframe/job/fixture/job/JobCaller.java
diff --git a/...ang/ddframe/job/fixture/job/OtherJob.java → ...ang/ddframe/job/fixture/job/OtherJob.java b/...ang/ddframe/job/fixture/job/OtherJob.java → ...ang/ddframe/job/fixture/job/OtherJob.java
diff --git a/...rame/job/fixture/job/TestDataflowJob.java → ...rame/job/fixture/job/TestDataflowJob.java b/...rame/job/fixture/job/TestDataflowJob.java → ...rame/job/fixture/job/TestDataflowJob.java
diff --git a/...dframe/job/fixture/job/TestSimpleJob.java → ...dframe/job/fixture/job/TestSimpleJob.java b/...dframe/job/fixture/job/TestSimpleJob.java → ...dframe/job/fixture/job/TestSimpleJob.java
diff --git a/...dangdang/ddframe/job/reg/AllRegTests.java → ...dangdang/ddframe/job/reg/AllRegTests.java b/...dangdang/ddframe/job/reg/AllRegTests.java → ...dangdang/ddframe/job/reg/AllRegTests.java
diff --git a/...eg/exception/RegExceptionHandlerTest.java → ...eg/exception/RegExceptionHandlerTest.java b/...eg/exception/RegExceptionHandlerTest.java → ...eg/exception/RegExceptionHandlerTest.java
diff --git a/...job/reg/zookeeper/EmbedTestingServer.java → ...job/reg/zookeeper/EmbedTestingServer.java b/...job/reg/zookeeper/EmbedTestingServer.java → ...job/reg/zookeeper/EmbedTestingServer.java
diff --git a/...zookeeper/ZookeeperConfigurationTest.java → ...zookeeper/ZookeeperConfigurationTest.java b/...zookeeper/ZookeeperConfigurationTest.java → ...zookeeper/ZookeeperConfigurationTest.java
diff --git a/...r/ZookeeperRegistryCenterForAuthTest.java → ...r/ZookeeperRegistryCenterForAuthTest.java b/...r/ZookeeperRegistryCenterForAuthTest.java → ...r/ZookeeperRegistryCenterForAuthTest.java
diff --git a/...okeeperRegistryCenterInitFailureTest.java → ...okeeperRegistryCenterInitFailureTest.java b/...okeeperRegistryCenterInitFailureTest.java → ...okeeperRegistryCenterInitFailureTest.java
diff --git a/...eeperRegistryCenterMiscellaneousTest.java → ...eeperRegistryCenterMiscellaneousTest.java b/...eeperRegistryCenterMiscellaneousTest.java → ...eeperRegistryCenterMiscellaneousTest.java
diff --git a/...er/ZookeeperRegistryCenterModifyTest.java → ...er/ZookeeperRegistryCenterModifyTest.java b/...er/ZookeeperRegistryCenterModifyTest.java → ...er/ZookeeperRegistryCenterModifyTest.java
diff --git a/...eperRegistryCenterQueryWithCacheTest.java → ...eperRegistryCenterQueryWithCacheTest.java b/...eperRegistryCenterQueryWithCacheTest.java → ...eperRegistryCenterQueryWithCacheTest.java
diff --git a/...rRegistryCenterQueryWithoutCacheTest.java → ...rRegistryCenterQueryWithoutCacheTest.java b/...rRegistryCenterQueryWithoutCacheTest.java → ...rRegistryCenterQueryWithoutCacheTest.java
diff --git a/...util/ZookeeperRegistryCenterTestUtil.java → ...util/ZookeeperRegistryCenterTestUtil.java b/...util/ZookeeperRegistryCenterTestUtil.java → ...util/ZookeeperRegistryCenterTestUtil.java
diff --git a/...ngdang/ddframe/job/util/AllUtilTests.java → ...ngdang/ddframe/job/util/AllUtilTests.java b/...ngdang/ddframe/job/util/AllUtilTests.java → ...ngdang/ddframe/job/util/AllUtilTests.java
diff --git a/...concurrent/ExecutorServiceObjectTest.java → ...concurrent/ExecutorServiceObjectTest.java b/...concurrent/ExecutorServiceObjectTest.java → ...concurrent/ExecutorServiceObjectTest.java
diff --git a/...il/config/ShardingItemParametersTest.java → ...il/config/ShardingItemParametersTest.java b/...il/config/ShardingItemParametersTest.java → ...il/config/ShardingItemParametersTest.java
diff --git a/...me/job/util/config/ShardingItemsTest.java → ...me/job/util/config/ShardingItemsTest.java b/...me/job/util/config/ShardingItemsTest.java → ...me/job/util/config/ShardingItemsTest.java
diff --git a/...frame/job/util/digest/EncryptionTest.java → ...frame/job/util/digest/EncryptionTest.java b/...frame/job/util/digest/EncryptionTest.java → ...frame/job/util/digest/EncryptionTest.java
diff --git a/...frame/job/util/env/HostExceptionTest.java → ...frame/job/util/env/HostExceptionTest.java b/...frame/job/util/env/HostExceptionTest.java → ...frame/job/util/env/HostExceptionTest.java
diff --git a/...me/job/util/env/LocalHostServiceTest.java → ...me/job/util/env/LocalHostServiceTest.java b/...me/job/util/env/LocalHostServiceTest.java → ...me/job/util/env/LocalHostServiceTest.java
diff --git a/...ddframe/job/util/env/TimeServiceTest.java → ...ddframe/job/util/env/TimeServiceTest.java b/...ddframe/job/util/env/TimeServiceTest.java → ...ddframe/job/util/env/TimeServiceTest.java
diff --git a/...dframe/job/util/json/GsonFactoryTest.java → ...dframe/job/util/json/GsonFactoryTest.java b/...dframe/job/util/json/GsonFactoryTest.java → ...dframe/job/util/json/GsonFactoryTest.java
diff --git a/.../JobConfigurationGsonTypeAdapterTest.java → .../JobConfigurationGsonTypeAdapterTest.java b/.../JobConfigurationGsonTypeAdapterTest.java → .../JobConfigurationGsonTypeAdapterTest.java
diff --git a/...ob/util/restful/RestfulExceptionTest.java → ...ob/util/restful/RestfulExceptionTest.java b/...ob/util/restful/RestfulExceptionTest.java → ...ob/util/restful/RestfulExceptionTest.java
diff --git a/...e/job/util/restful/RestfulServerTest.java → ...e/job/util/restful/RestfulServerTest.java b/...e/job/util/restful/RestfulServerTest.java → ...e/job/util/restful/RestfulServerTest.java
diff --git a/...rame/job/util/restful/fixture/Caller.java → ...rame/job/util/restful/fixture/Caller.java b/...rame/job/util/restful/fixture/Caller.java → ...rame/job/util/restful/fixture/Caller.java
diff --git a/.../util/restful/fixture/TestRestfulApi.java → .../util/restful/fixture/TestRestfulApi.java b/.../util/restful/fixture/TestRestfulApi.java → .../util/restful/fixture/TestRestfulApi.java
diff --git a/.../test/resources/conf/reg/local.properties → .../test/resources/conf/reg/local.properties b/.../test/resources/conf/reg/local.properties → .../test/resources/conf/reg/local.properties
diff --git a/...urces/conf/reg/local_overwrite.properties → ...urces/conf/reg/local_overwrite.properties b/...urces/conf/reg/local_overwrite.properties → ...urces/conf/reg/local_overwrite.properties
diff --git a/...-core/src/test/resources/logback-test.xml → ...-core/src/test/resources/logback-test.xml b/...-core/src/test/resources/logback-test.xml → ...-core/src/test/resources/logback-test.xml
diff --git a/elastic-job-common/pom.xml b/elastic-job-common/pom.xml
@@ -11,6 +11,6 @@
     <name>${project.artifactId}</name>
 
     <modules>
-        <module>elastic-job-core</module>
+        <module>elastic-job-common-core</module>
     </modules>
 </project>