提交 9624875d 编写于 作者: S StephanEwen

Fixed erroneous cluster mode instantiation.

上级 7671b33b
......@@ -141,7 +141,7 @@ import eu.stratosphere.nephele.util.StringUtils;
public class JobManager implements DeploymentManager, ExtendedManagementProtocol, InputSplitProviderProtocol,
JobManagerProtocol, ChannelLookupProtocol, JobStatusListener, PluginCommunicationProtocol {
public static enum ExecutionMode { LOCAL, CLUSTER, CLOUD }
public static enum ExecutionMode { LOCAL, CLUSTER }
// --------------------------------------------------------------------------------------------
......@@ -404,10 +404,8 @@ public class JobManager implements DeploymentManager, ExtendedManagementProtocol
final ExecutionMode executionMode;
if ("local".equals(executionModeName)) {
executionMode = ExecutionMode.LOCAL;
} else if ("local".equals(executionModeName)) {
} else if ("cluster".equals(executionModeName)) {
executionMode = ExecutionMode.CLUSTER;
} else if ("local".equals(executionModeName)) {
executionMode = ExecutionMode.CLOUD;
} else {
System.err.println("Unrecognized execution mode: " + executionModeName);
System.exit(FAILURERETURNCODE);
......
......@@ -151,8 +151,6 @@ public class JobManagerUtils {
return "eu.stratosphere.nephele.jobmanager.scheduler.local.LocalScheduler";
case CLUSTER:
return "eu.stratosphere.nephele.jobmanager.scheduler.queue.QueueScheduler";
case CLOUD:
return "eu.stratosphere.nephele.jobmanager.scheduler.queue.QueueScheduler";
default:
throw new RuntimeException("Unrecognized Execution Mode.");
}
......@@ -180,8 +178,6 @@ public class JobManagerUtils {
return "eu.stratosphere.nephele.instance.local.LocalInstanceManager";
case CLUSTER:
return "eu.stratosphere.nephele.instance.cluster.ClusterManager";
case CLOUD:
return "eu.stratosphere.nephele.instance.ec2.EC2CloudManager";
default:
throw new RuntimeException("Unrecognized Execution Mode.");
}
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册