Skip to content

D
data-adapter
Commit a3b41ab1 by hy
Options

add necessary api for console end-point

parent 84bc4b27
Showing with 2 additions and 0 deletions
dataadapter-core/src/main/java/com/tbyf/dataadapter/task/Task.java
...@@ -9,4 +9,5 @@ public class Task { ...@@ -9,4 +9,5 @@ public class Task {
private String description; private String description;
private int parallelism; private int parallelism;
private TaskState state; private TaskState state;
private TaskDef taskDef;
} }
dataadapter-core/src/main/java/com/tbyf/dataadapter/task/TaskManager.java
...@@ -40,6 +40,7 @@ public class TaskManager { ...@@ -40,6 +40,7 @@ public class TaskManager {
task.setId(taskId); task.setId(taskId);
task.setDescription(taskDef.getDescription()); task.setDescription(taskDef.getDescription());
task.setState(TaskState.NEW); task.setState(TaskState.NEW);
task.setTaskDef(taskDef);
int cpuNums = Utils.getCpuNums(); int cpuNums = Utils.getCpuNums();
int parallelism = taskDef.getParallelism(); int parallelism = taskDef.getParallelism();
if (parallelism > cpuNums) { if (parallelism > cpuNums) {
......
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