This closes: #47 Review: https://github.com/apache/incubator-myriad/pull/47
Prepended FrameworkName to the task-name Removed the 'task' declaration in taskName per git discussion Project: http://git-wip-us.apache.org/repos/asf/incubator-myriad/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-myriad/commit/7e54db01 Tree: http://git-wip-us.apache.org/repos/asf/incubator-myriad/tree/7e54db01 Diff: http://git-wip-us.apache.org/repos/asf/incubator-myriad/diff/7e54db01 Branch: refs/heads/master Commit: 7e54db015b2a94e44379973ef06c96ff7a0311d9 Parents: fe941a6 Author: Brandon Gulla <bran...@brandongulla.com> Authored: Wed Nov 18 12:51:49 2015 -0500 Committer: Ken Sipe <kens...@gmail.com> Committed: Wed Nov 18 13:26:07 2015 -0600 ---------------------------------------------------------------------- .../src/main/java/org/apache/myriad/scheduler/TaskFactory.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-myriad/blob/7e54db01/myriad-scheduler/src/main/java/org/apache/myriad/scheduler/TaskFactory.java ---------------------------------------------------------------------- diff --git a/myriad-scheduler/src/main/java/org/apache/myriad/scheduler/TaskFactory.java b/myriad-scheduler/src/main/java/org/apache/myriad/scheduler/TaskFactory.java index 00de037..8412eba 100644 --- a/myriad-scheduler/src/main/java/org/apache/myriad/scheduler/TaskFactory.java +++ b/myriad-scheduler/src/main/java/org/apache/myriad/scheduler/TaskFactory.java @@ -184,7 +184,7 @@ public interface TaskFactory { CommandInfo commandInfo = getCommandInfo(serviceProfile, ports); ExecutorInfo executorInfo = getExecutorInfoForSlave(frameworkId, offer, commandInfo); - TaskInfo.Builder taskBuilder = TaskInfo.newBuilder().setName(cfg.getFrameworkName() + "-task-" + taskId.getValue()).setTaskId(taskId).setSlaveId( + TaskInfo.Builder taskBuilder = TaskInfo.newBuilder().setName(cfg.getFrameworkName() + "-" + taskId.getValue()).setTaskId(taskId).setSlaveId( offer.getSlaveId()); return taskBuilder
