@@ -0,0 +1,1315 @@
+import pytest%0A%0Afrom hdfs.client import Client%0A%0Aimport utils%0A%0A%0Adef setup_module(module):%0A    utils.invoke('install', 'spark')%0A%0A%0A@utils.vagranttest%0Adef test_salt_formulas():%0A    project = utils.get_test_project()%0A%0A    kwargs = %7B'test': 'true', '--out': 'json', '--out-indent': '-1'%7D%0A    out = project.salt('state.sls', args=%5B'cdh5.zookeeper'%5D, kwargs=kwargs)%0A    utils.check_all_true(out, none_is_ok=True)%0A%0A    kwargs = %7B'test': 'true', '--out': 'json', '--out-indent': '-1'%7D%0A    out = project.salt('state.sls', args=%5B'cdh5.hdfs.cluster'%5D, kwargs=kwargs)%0A    utils.check_all_true(out, none_is_ok=True)%0A%0A    kwargs = %7B'test': 'true', '--out': 'json', '--out-indent': '-1'%7D%0A    out = project.salt('state.sls', args=%5B'mesos.cluster'%5D, kwargs=kwargs)%0A    utils.check_all_true(out, none_is_ok=True)%0A%0A    kwargs = %7B'test': 'true', '--out': 'json', '--out-indent': '-1'%7D%0A    out = project.salt('state.sls', args=%5B'mesos.spark'%5D, kwargs=kwargs)%0A    utils.check_all_true(out, none_is_ok=True)%0A%0A%0A@utils.vagranttest%0Adef test_hdfs_files():%0A    project = utils.get_test_project()%0A    master_ip = project.cluster.master.ip%0A    hdfs = Client('http://%25s:50070' %25 master_ip)%0A%0A    root_dirs = hdfs.list('/')%0A    assert 'spark' in root_dirs%0A%0A    spark_dirs = hdfs.list('/spark')%0A    assert 'spark-1.4.1-bin-hadoop2.6.tgz' in spark_dirs%0A

Add simple spark on mesos test