HdfsMesosTestCase.java 文件源码

@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());
}