Skip to content

Commit

Permalink
Fixed #160.
Browse files Browse the repository at this point in the history
  • Loading branch information
@haocao
haocao committed Nov 10, 2016
1 parent af127ef commit f17e0ae
Show file tree
Hide file tree
Showing 31 changed files with 114 additions and 35 deletions.
1 change: 1 addition & 0 deletions ...-scheduler/src/main/java/com/dangdang/ddframe/job/cloud/scheduler/context/JobContext.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -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;

Expand Down
2 changes: 1 addition & 1 deletion ...er/src/main/java/com/dangdang/ddframe/job/cloud/scheduler/lifecycle/LifecycleService.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -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;
Expand Down
4 changes: 2 additions & 2 deletions ...scheduler/src/main/java/com/dangdang/ddframe/job/cloud/scheduler/mesos/FacadeService.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -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;
Expand Down
2 changes: 1 addition & 1 deletion ...cheduler/src/main/java/com/dangdang/ddframe/job/cloud/scheduler/mesos/JobTaskRequest.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -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;
Expand Down
4 changes: 2 additions & 2 deletions ...cheduler/src/main/java/com/dangdang/ddframe/job/cloud/scheduler/mesos/LaunchingTasks.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -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;
Expand Down
2 changes: 1 addition & 1 deletion ...heduler/src/main/java/com/dangdang/ddframe/job/cloud/scheduler/mesos/SchedulerEngine.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -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;
Expand Down
2 changes: 1 addition & 1 deletion ...ler/src/main/java/com/dangdang/ddframe/job/cloud/scheduler/mesos/TaskLaunchProcessor.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -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;
Expand Down
2 changes: 1 addition & 1 deletion ...r/src/main/java/com/dangdang/ddframe/job/cloud/scheduler/state/failover/FailoverNode.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -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;
Expand Down
4 changes: 2 additions & 2 deletions ...rc/main/java/com/dangdang/ddframe/job/cloud/scheduler/state/failover/FailoverService.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -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;
Expand Down
2 changes: 1 addition & 1 deletion ...uler/src/main/java/com/dangdang/ddframe/job/cloud/scheduler/state/ready/ReadyService.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -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;
Expand Down
2 changes: 1 addition & 1 deletion .../src/main/java/com/dangdang/ddframe/job/cloud/scheduler/state/running/RunningService.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -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;
Expand Down
3 changes: 1 addition & 2 deletions ...duler/src/test/java/com/dangdang/ddframe/job/cloud/scheduler/context/AllContextTests.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -22,8 +22,7 @@

@RunWith(Suite.class)
@Suite.SuiteClasses({
JobContextTest.class,
TaskContextTest.class
JobContextTest.class
})
public final class AllContextTests {
}
1 change: 1 addition & 0 deletions ...eduler/src/test/java/com/dangdang/ddframe/job/cloud/scheduler/context/JobContextTest.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -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;
Expand Down
2 changes: 1 addition & 1 deletion ...ud-scheduler/src/test/java/com/dangdang/ddframe/job/cloud/scheduler/fixture/TaskNode.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -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;

Expand Down
2 changes: 1 addition & 1 deletion ...rc/test/java/com/dangdang/ddframe/job/cloud/scheduler/lifecycle/LifecycleServiceTest.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -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;
Expand Down
4 changes: 2 additions & 2 deletions ...duler/src/test/java/com/dangdang/ddframe/job/cloud/scheduler/mesos/FacadeServiceTest.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -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;
Expand Down
4 changes: 2 additions & 2 deletions ...uler/src/test/java/com/dangdang/ddframe/job/cloud/scheduler/mesos/JobTaskRequestTest.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -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;
Expand Down
2 changes: 1 addition & 1 deletion ...uler/src/test/java/com/dangdang/ddframe/job/cloud/scheduler/mesos/LaunchingTasksTest.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -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;
Expand Down
4 changes: 2 additions & 2 deletions ...ler/src/test/java/com/dangdang/ddframe/job/cloud/scheduler/mesos/SchedulerEngineTest.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -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;
Expand Down
2 changes: 1 addition & 1 deletion .../src/test/java/com/dangdang/ddframe/job/cloud/scheduler/producer/ProducerManagerTest.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -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;
Expand Down
2 changes: 1 addition & 1 deletion ...c/test/java/com/dangdang/ddframe/job/cloud/scheduler/state/failover/FailoverNodeTest.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -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;

Expand Down
4 changes: 2 additions & 2 deletions ...est/java/com/dangdang/ddframe/job/cloud/scheduler/state/failover/FailoverServiceTest.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -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;
Expand Down
2 changes: 1 addition & 1 deletion .../src/test/java/com/dangdang/ddframe/job/cloud/scheduler/state/ready/ReadyServiceTest.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -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;
Expand Down
2 changes: 1 addition & 1 deletion .../test/java/com/dangdang/ddframe/job/cloud/scheduler/state/running/RunningServiceTest.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -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;
Expand Down
2 changes: 1 addition & 1 deletion ...loud/scheduler/context/ExecutionType.java → ...ng/ddframe/job/context/ExecutionType.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -15,7 +15,7 @@
* </p>
*/

package com.dangdang.ddframe.job.cloud.scheduler.context;
package com.dangdang.ddframe.job.context;

/**
* 执行类型.
Expand Down
2 changes: 1 addition & 1 deletion .../cloud/scheduler/context/TaskContext.java → ...dang/ddframe/job/context/TaskContext.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -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;
Expand Down
4 changes: 4 additions & 0 deletions ...-job-core/src/main/java/com/dangdang/ddframe/job/executor/AbstractElasticJobExecutor.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -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;
Expand Down Expand Up @@ -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);
}
Expand Down
28 changes: 28 additions & 0 deletions ...mmon/elastic-job-core/src/test/java/com/dangdang/ddframe/job/context/AllContextTests.java
View file
Original file line number Diff line number Diff line change
@@ -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 {
}
7 changes: 4 additions & 3 deletions ...ud/scheduler/context/TaskContextTest.java → .../ddframe/job/context/TaskContextTest.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -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;
Expand Down Expand Up @@ -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));
Expand Down
44 changes: 44 additions & 0 deletions ...mon/elastic-job-core/src/test/java/com/dangdang/ddframe/job/fixture/context/TaskNode.java
View file
Original file line number Diff line number Diff line change
@@ -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);
}
}
1 change: 1 addition & 0 deletions elastic-job-doc/content/post/release_notes.md
View file
Original file line number Diff line number Diff line change
Expand Up @@ -21,6 +21,7 @@ weight=1
### 结构调整

1. [ISSUE #153](https://github.com/dangdangdotcom/elastic-job/issues/153) 事件追踪配置集中化
1. [ISSUE #160](https://github.com/dangdangdotcom/elastic-job/issues/160) 调整maven模块结构，提供elastic-job-common及其二级模块

## 2.0.1

Expand Down

0 comments on commit f17e0ae

Please sign in to comment.