Apache Spark Tutorial Python With PySpark 4 | Run our first Spark job

This Apache Spark Tutorial covers all the fundamentals about Apache Spark with Python and teaches you everything you need to know about developing Spark applications using PySpark, the Python API for Spark.

Apache Spark Tutorial | Spark tutorial | Apache tutorial

At the end of this Apache Spark Tutorial, you will gain in-depth knowledge about Apache Spark and general big data analysis and manipulations skills to help your company to adapt Apache Spark for building big data processing pipeline and data analytics applications.

Apache Spark Tutorial | Spark tutorial | Apache tutorial

This Apache Spark Tutorial covers 10+ hands-on big data examples. You will learn valuable knowledge about how to frame data analysis problems as Spark problems.

Together we will learn examples such as aggregating NASA Apache web logs from different sources; we will explore the price trend by looking at the real estate data in California; we will write Spark applications to find out the median salary of developers in different countries through the Stack Overflow survey data; we will develop a system to analyze how maker spaces are distributed across different regions in the United Kingdom. And much much more.

Apache Spark Tutorial | Spark tutorial | Apache tutorial

What will you learn from this Apache Spark Tutorial:

In particularly, you will learn:

An overview of the architecture of Apache Spark.
Develop Apache Spark 2.0 applications with PySpark using RDD transformations and actions and Spark SQL.
Work with Apache Spark's primary abstraction, resilient distributed datasets(RDDs) to process and analyze large data sets.
Deep dive into advanced techniques to optimize and tune Apache Spark jobs by partitioning, caching and persisting RDDs.
Scale up Spark applications on a Hadoop YARN cluster through Amazon's Elastic MapReduce service.
Analyze structured and semi-structured data using Datasets and DataFrames, and develop a thorough understanding of Spark SQL.
Share information across different nodes on an Apache Spark cluster by broadcast variables and accumulators.
Best practices of working with Apache Spark in the field.
Big data ecosystem overview.

Apache Spark Tutorial | Spark tutorial | Apache tutorial

[rajr]

Though it is a very simple code, explained well. Very helpful for a beginner like me. Thank You.

[damwyn]

When do we need SparkSession ? Most of the tutorials shows how to create SparkSession at the beginning, but it seems that you don't need to. I'm confused

[vijaysinghrajput]

very well done..!!! Thanks for contributing knowledge to open source community

[sriharikusumanchi]

I have set up the spark in my windows machine whereas from the command prompt i was able to launch Pyspark and Spark-shell
But when I’m trying to configure the Pyspark in Pycharm It’s throwing below error

‘cmd’ is not recognized as an internal or external command,
operable program or batch file.
Traceback (most recent call last):
File “C:/Users/SKusumanchi/PycharmProjects/Test/prac/SparkTest.py”, line 2, in
spark =
File “C:\spark-2.2.0-bin-hadoop2.6\python\pyspark\sql\session.py”, line 169, in getOrCreate
sc =
File “C:\spark-2.2.0-bin-hadoop2.6\python\pyspark\context.py”, line 334, in getOrCreate
SparkContext(conf=conf or SparkConf())
File “C:\spark-2.2.0-bin-hadoop2.6\python\pyspark\context.py”, line 115, in init
SparkContext._ensure_initialized(self, gateway=gateway, conf=conf)
File “C:\spark-2.2.0-bin-hadoop2.6\python\pyspark\context.py”, line 283, in _ensure_initialized
SparkContext._gateway = gateway or launch_gateway(conf)
File “C:\spark-2.2.0-bin-hadoop2.6\python\pyspark\java_gateway.py”, line 95, in launch_gateway
raise Exception(“Java gateway process exited before sending the driver its port number”)
Exception: Java gateway process exited before sending the driver its port number

Process finished with exit code 1

Sample code is for the error is:

from pyspark.sql import SparkSession
spark =


Please help me guys it’s been two days i have been unable to overcome this issue. The python Version is 2.7 and Spark version is 2.2.0, i believe these versions are compatible since Pyspark sell was launched successfully from Command prompt and able to read data from the pyspark shell

[KASANITEJ]

for ppl who have issues running on windows... install java version 8... I have Java 11 and it is throwing me errors

[maderaanalytics]

Hello I am follow your tutorial I am using WLS Ubuntu distribution and I got the following error: 20/04/23 13:36:29 INFO SparkContext: Created broadcast 0 from textFile at
20/04/23 13:36:29 INFO FileInputFormat: Total input paths to process : 1
Traceback (most recent call last):
File "/mnt/c/Users/Manny.Madera/Documents/python_spark/python-spark-tutorial/rdd/WordCount.py", line 11, in <module>
wordCounts = words.countByValue()
File "/opt/apachespark/spark-2.4.5-bin-hadoop2.7/python/lib/pyspark.zip/pyspark/rdd.py", line 1261, in countByValue
File "/opt/apachespark/spark-2.4.5-bin-hadoop2.7/python/lib/pyspark.zip/pyspark/rdd.py", line 844, in reduce
File "/opt/apachespark/spark-2.4.5-bin-hadoop2.7/python/lib/pyspark.zip/pyspark/rdd.py", line 816, in collect
File "/opt/apachespark/spark-2.4.5-bin-hadoop2.7/python/lib/py4j-0.10.7-src.zip/py4j/java_gateway.py", line 1257, in __call__
File "/opt/apachespark/spark-2.4.5-bin-hadoop2.7/python/lib/py4j-0.10.7-src.zip/py4j/protocol.py", line 328, in get_return_value
py4j.protocol.Py4JJavaError: An error occurred while calling


Any Idea to fix this I have both Java and spark