diff --git a/src/main/scala/thoughtworks/Diamond.scala b/src/main/scala/thoughtworks/Diamond.scala
index 6f08927..bd609d4 100644
--- a/src/main/scala/thoughtworks/Diamond.scala
+++ b/src/main/scala/thoughtworks/Diamond.scala
@@ -5,7 +5,11 @@ import org.apache.spark.sql.SparkSession
 
 object Diamond {
   def main(args: Array[String]): Unit = {
-    val spark = SparkSession.builder().appName("Analyze Diamond Data Spark App").getOrCreate()
+    val spark = SparkSession
+      .builder()
+      .master("local")
+      .appName("Analyze Diamond Data Spark App")
+      .getOrCreate()
 
     //Create dataframe from src/main/resources/diamonds.csv
     val diamondDF = spark.emptyDataFrame