@Before
public void before() throws Exception {
BasicConfigurator.configure();
Scheduler.$.initLogging();
File storageFile = Files.createTempFile(MesosTestCase.class.getSimpleName(), null).toFile();
assertTrue(storageFile.delete());
Nodes.storage = Storage.file(storageFile);
Nodes.reset();
Scheduler.Config config = Scheduler.$.config;
config.api = "http://localhost:" + Net.findAvailPort();
config.jar = new File("hdfs-mesos-0.1.jar");
config.hadoop = new File("hadoop-1.2.1.tar.gz");
Cli.api = config.api;
Scheduler.$.subscribed(schedulerDriver, "id", new Master());
}
HdfsMesosTestCase.java 文件源码
java
阅读 21
收藏 0
点赞 0
评论 0
项目:hdfs-mesos
作者:
评论列表
文章目录