github
/
k3s
mirror of https://github.com/k3s-io/k3s
1
0
Fork 0
Code Issues Projects Releases Wiki Activity

added test for spark driver too

pull/6/head
Gurvinder Singh 2015-07-30 09:47:56 +02:00
parent f64d89fd1d
commit e1d76d5f19
2 changed files with 6 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
examples/examples_test.go
View File

@ -317,6 +317,7 @@ func TestExampleObjectSchemas(t *testing.T) {
"spark-master-service": &api.Service{}, "spark-master-service": &api.Service{},
"spark-master": &api.Pod{}, "spark-master": &api.Pod{},
"spark-worker-controller": &api.ReplicationController{}, "spark-worker-controller": &api.ReplicationController{},
"spark-driver": &api.Pod{},
}, },
"../examples/storm": { "../examples/storm": {
"storm-nimbus-service": &api.Service{}, "storm-nimbus-service": &api.Service{},

6
test/e2e/examples.go
View File

@ -159,22 +159,26 @@ var _ = Describe("Examples e2e", func() {
}) })
Describe("[Skipped][Example]Spark", 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 { mkpath := func(file string) string {
return filepath.Join(testContext.RepoRoot, "examples", "spark", file) return filepath.Join(testContext.RepoRoot, "examples", "spark", file)
} }
serviceJson := mkpath("spark-master-service.json") serviceJson := mkpath("spark-master-service.json")
masterJson := mkpath("spark-master.json") masterJson := mkpath("spark-master.json")
driverJson := mkpath("spark-driver.json")
workerControllerJson := mkpath("spark-worker-controller.json") workerControllerJson := mkpath("spark-worker-controller.json")
nsFlag := fmt.Sprintf("--namespace=%v", ns) nsFlag := fmt.Sprintf("--namespace=%v", ns)
By("starting master") By("starting master")
runKubectl("create", "-f", serviceJson, nsFlag) runKubectl("create", "-f", serviceJson, nsFlag)
runKubectl("create", "-f", masterJson, nsFlag) runKubectl("create", "-f", masterJson, nsFlag)
runKubectl("create", "-f", driverJson, nsFlag)
err := waitForPodRunningInNamespace(c, "spark-master", ns) err := waitForPodRunningInNamespace(c, "spark-master", ns)
Expect(err).NotTo(HaveOccurred()) Expect(err).NotTo(HaveOccurred())
_, err = lookForStringInLog(ns, "spark-master", "spark-master", "Starting Spark master at", serverStartTimeout) _, err = lookForStringInLog(ns, "spark-master", "spark-master", "Starting Spark master at", serverStartTimeout)
Expect(err).NotTo(HaveOccurred()) Expect(err).NotTo(HaveOccurred())
_, err = lookForStringInLog(ns, "spark-driver", "spark-driver", "Starting Spark driver at", serverStartTimeout)
Expect(err).NotTo(HaveOccurred())
By("starting workers") By("starting workers")
runKubectl("create", "-f", workerControllerJson, nsFlag) runKubectl("create", "-f", workerControllerJson, nsFlag)