From 9b706060d82dddeccc3c1d72a3a43daa87c0730b Mon Sep 17 00:00:00 2001 From: Sanjyot Bandal Date: Wed, 29 May 2019 22:34:28 +0530 Subject: [PATCH] remove extra blank before class argument which failed the launching of Main class & set master to local --- README.md | 2 +- src/main/scala/thoughtworks/Diamond.scala | 6 +++++- 2 files changed, 6 insertions(+), 2 deletions(-) diff --git a/README.md b/README.md index d1e8195..493408e 100644 --- a/README.md +++ b/README.md @@ -34,4 +34,4 @@ How to run spark program through Intellij? - Set main class as org.apache.spark.deploy.SparkSubmit - Set program arguments as - --master local -- class target/scala-2.12/ + --master local --class target/scala-2.12/ diff --git a/src/main/scala/thoughtworks/Diamond.scala b/src/main/scala/thoughtworks/Diamond.scala index c703876..c1c3ac8 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() val diamondDF = spark.read .option("header", true)