add test to check the local mode for JobTest

twitter · Mar 14, 2018 · c3119fb · c3119fb
1 parent 20467aa
commit c3119fb
Showing 1 changed file with 5 additions and 0 deletions.
diff --git a/scalding-core/src/test/scala/com/twitter/scalding/JobTestTest.scala b/scalding-core/src/test/scala/com/twitter/scalding/JobTestTest.scala
@@ -35,5 +35,10 @@ class JobTestTest extends WordSpec with Matchers {
         runJobTest()
       } should have message (s"Failed to create tap for: ${requiredSource}, with error: requirement failed: " + TestTapFactory.sourceNotFoundError.format(requiredSource))
     }
+    "use local mode by default" in {
+      JobTest(new SimpleTestJob(_)).getTestMode(true, None) match {
+        case m: HadoopTest => m.jobConf.get("mapreduce.framework.name") shouldBe "local"
+      }
+    }
   }
 }