From e1d76d5f19e84f87d4e7e51618a38ade9eda524c Mon Sep 17 00:00:00 2001 From: Gurvinder Singh Date: Thu, 30 Jul 2015 09:47:56 +0200 Subject: [PATCH] added test for spark driver too --- examples/examples_test.go | 1 + test/e2e/examples.go | 6 +++++- 2 files changed, 6 insertions(+), 1 deletion(-) diff --git a/examples/examples_test.go b/examples/examples_test.go index bdad9c9b06..d5e42f526a 100644 --- a/examples/examples_test.go +++ b/examples/examples_test.go @@ -317,6 +317,7 @@ func TestExampleObjectSchemas(t *testing.T) { "spark-master-service": &api.Service{}, "spark-master": &api.Pod{}, "spark-worker-controller": &api.ReplicationController{}, + "spark-driver": &api.Pod{}, }, "../examples/storm": { "storm-nimbus-service": &api.Service{}, diff --git a/test/e2e/examples.go b/test/e2e/examples.go index 75a8d6de6b..6c3d4ef309 100644 --- a/test/e2e/examples.go +++ b/test/e2e/examples.go @@ -159,22 +159,26 @@ var _ = Describe("Examples e2e", func() { }) Describe("[Skipped][Example]Spark", func() { - It("should start spark master and workers", func() { + It("should start spark master, driver and workers", func() { mkpath := func(file string) string { return filepath.Join(testContext.RepoRoot, "examples", "spark", file) } serviceJson := mkpath("spark-master-service.json") masterJson := mkpath("spark-master.json") + driverJson := mkpath("spark-driver.json") workerControllerJson := mkpath("spark-worker-controller.json") nsFlag := fmt.Sprintf("--namespace=%v", ns) By("starting master") runKubectl("create", "-f", serviceJson, nsFlag) runKubectl("create", "-f", masterJson, nsFlag) + runKubectl("create", "-f", driverJson, nsFlag) err := waitForPodRunningInNamespace(c, "spark-master", ns) Expect(err).NotTo(HaveOccurred()) _, err = lookForStringInLog(ns, "spark-master", "spark-master", "Starting Spark master at", serverStartTimeout) Expect(err).NotTo(HaveOccurred()) + _, err = lookForStringInLog(ns, "spark-driver", "spark-driver", "Starting Spark driver at", serverStartTimeout) + Expect(err).NotTo(HaveOccurred()) By("starting workers") runKubectl("create", "-f", workerControllerJson, nsFlag)