Spark Core interview questions

75 real Spark Core questions from the Big Data bank, as asked in Indian campus drives and tech interviews. Every question has a verified answer and an AI-tutor explanation on placd — free to start.

1. What is Spark action?

Junior
  1. A.an operation that triggers execution and returns a result (collect, count, save)
  2. B.a shared write-only variable in Spark that workers add to and the driver reads, used for counters and metrics
  3. C.a set of tasks that can run without a shuffle, bounded by shuffle (wide) dependencies in the DAG
  4. D.a transformation needing no shuffle, where one input partition maps to one output partition
Reveal the answer + AI explanation — free account

3. Which statement is correct?

Junior
  1. A.Spark action — the Spark process that runs the main function, creates the SparkContext, builds the DAG, and coordinates tasks across executors
  2. B.Spark action — an operation that triggers execution and returns a result (collect, count, save)
  3. C.Spark action — a long-running auxiliary process that serves shuffle blocks so executors can be removed under dynamic allocation without losing shuffle data
  4. D.Spark action — the basic unit of parallelism in Spark, a logical chunk of a dataset that one task processes
Reveal the answer + AI explanation — free account

4. What is Spark transformation?

Junior
  1. A.truncating an RDD's lineage by saving it to reliable storage so recovery does not recompute a long chain of transformations
  2. B.the smallest unit of execution in Spark, operating on a single partition of data within a stage
  3. C.reduces the number of partitions without a full shuffle
  4. D.a lazy operation that returns a new RDD/DataFrame without executing (map, filter, join)
Reveal the answer + AI explanation — free account

6. Which statement is correct?

Junior
  1. A.Spark transformation — the Spark process that runs the main function, creates the SparkContext, builds the DAG, and coordinates tasks across executors
  2. B.Spark transformation — a lazy operation that returns a new RDD/DataFrame without executing (map, filter, join)
  3. C.Spark transformation — memory Spark manages outside the JVM heap (spark.memory.offHeap) to reduce garbage-collection overhead for execution and storage
  4. D.Spark transformation — a transformation requiring a shuffle, which creates a stage boundary
Reveal the answer + AI explanation — free account

7. What is narrow transformation?

Junior
  1. A.a transformation requiring a shuffle, which creates a stage boundary
  2. B.the point created by a shuffle (wide dependency) that splits a job into stages
  3. C.memory Spark manages outside the JVM heap (spark.memory.offHeap) to reduce garbage-collection overhead for execution and storage
  4. D.a transformation needing no shuffle, where one input partition maps to one output partition
Reveal the answer + AI explanation — free account

9. Which statement is correct?

Junior
  1. A.narrow transformation — redistributes data into N partitions with a full shuffle
  2. B.narrow transformation — a transformation requiring a shuffle, which creates a stage boundary
  3. C.narrow transformation — a transformation needing no shuffle, where one input partition maps to one output partition
  4. D.narrow transformation — a lazy operation that returns a new RDD/DataFrame without executing (map, filter, join)
Reveal the answer + AI explanation — free account

10. What is wide transformation?

Junior
  1. A.the process that builds the DAG and schedules tasks
  2. B.an operation that triggers execution and returns a result (collect, count, save)
  3. C.a transformation requiring a shuffle, which creates a stage boundary
  4. D.a shared write-only variable in Spark that workers add to and the driver reads, used for counters and metrics
Reveal the answer + AI explanation — free account

12. Which statement is correct?

Junior
  1. A.wide transformation — truncating an RDD's lineage by saving it to reliable storage so recovery does not recompute a long chain of transformations
  2. B.wide transformation — a transformation requiring a shuffle, which creates a stage boundary
  3. C.wide transformation — reduces the number of partitions without a full shuffle
  4. D.wide transformation — a Spark mechanism that scales the number of executors up and down at runtime based on pending and running task load
Reveal the answer + AI explanation — free account

13. What is RDD lineage?

Mid
  1. A.a Spark feature that re-launches duplicate copies of slow-running tasks (stragglers) and uses whichever finishes first
  2. B.the recorded chain of transformations used to recompute lost partitions
  3. C.redistributes data into N partitions with a full shuffle
  4. D.a long-running auxiliary process that serves shuffle blocks so executors can be removed under dynamic allocation without losing shuffle data
Reveal the answer + AI explanation — free account

15. Which statement is correct?

Mid
  1. A.RDD lineage — a lazy operation that returns a new RDD/DataFrame without executing (map, filter, join)
  2. B.RDD lineage — a transformation needing no shuffle, where one input partition maps to one output partition
  3. C.RDD lineage — the recorded chain of transformations used to recompute lost partitions
  4. D.RDD lineage — the model where execution and storage share one region and can borrow each other's space, with execution able to evict cached blocks
Reveal the answer + AI explanation — free account

16. What is stage boundary?

Mid
  1. A.the point created by a shuffle (wide dependency) that splits a job into stages
  2. B.a JVM process launched on a worker node that runs tasks and holds cached data in memory or on disk for a single application
  3. C.the recorded chain of transformations used to recompute lost partitions
  4. D.a transformation needing no shuffle, where one input partition maps to one output partition
Reveal the answer + AI explanation — free account

18. Which statement is correct?

Mid
  1. A.stage boundary — a lazy operation that returns a new RDD/DataFrame without executing (map, filter, join)
  2. B.stage boundary — the point created by a shuffle (wide dependency) that splits a job into stages
  3. C.stage boundary — a long-running auxiliary process that serves shuffle blocks so executors can be removed under dynamic allocation without losing shuffle data
  4. D.stage boundary — a shared write-only variable in Spark that workers add to and the driver reads, used for counters and metrics
Reveal the answer + AI explanation — free account

19. What is coalesce()?

Mid
  1. A.the recorded chain of transformations used to recompute lost partitions
  2. B.a transformation needing no shuffle, where one input partition maps to one output partition
  3. C.the Spark process that runs the main function, creates the SparkContext, builds the DAG, and coordinates tasks across executors
  4. D.reduces the number of partitions without a full shuffle
Reveal the answer + AI explanation — free account

21. Which statement is correct?

Mid
  1. A.coalesce() — an operation that triggers execution and returns a result (collect, count, save)
  2. B.coalesce() — memory Spark manages outside the JVM heap (spark.memory.offHeap) to reduce garbage-collection overhead for execution and storage
  3. C.coalesce() — a long-running auxiliary process that serves shuffle blocks so executors can be removed under dynamic allocation without losing shuffle data
  4. D.coalesce() — reduces the number of partitions without a full shuffle
Reveal the answer + AI explanation — free account

22. What is repartition()?

Mid
  1. A.the process that builds the DAG and schedules tasks
  2. B.the process that runs tasks and holds cached data
  3. C.a Spark mechanism that scales the number of executors up and down at runtime based on pending and running task load
  4. D.redistributes data into N partitions with a full shuffle
Reveal the answer + AI explanation — free account

24. Which statement is correct?

Mid
  1. A.repartition() — a transformation needing no shuffle, where one input partition maps to one output partition
  2. B.repartition() — redistributes data into N partitions with a full shuffle
  3. C.repartition() — a transformation requiring a shuffle, which creates a stage boundary
  4. D.repartition() — the basic unit of parallelism in Spark, a logical chunk of a dataset that one task processes
Reveal the answer + AI explanation — free account

25. What is Spark driver?

Junior
  1. A.the process that builds the DAG and schedules tasks
  2. B.a JVM process launched on a worker node that runs tasks and holds cached data in memory or on disk for a single application
  3. C.a scheduling mode that launches all tasks of a stage together (gang scheduling) for distributed ML workloads like deep learning
  4. D.a long-running auxiliary process that serves shuffle blocks so executors can be removed under dynamic allocation without losing shuffle data
Reveal the answer + AI explanation — free account

27. Which statement is correct?

Junior
  1. A.Spark driver — the smallest unit of execution in Spark, operating on a single partition of data within a stage
  2. B.Spark driver — a long-running auxiliary process that serves shuffle blocks so executors can be removed under dynamic allocation without losing shuffle data
  3. C.Spark driver — the model where execution and storage share one region and can borrow each other's space, with execution able to evict cached blocks
  4. D.Spark driver — the process that builds the DAG and schedules tasks
Reveal the answer + AI explanation — free account

28. What is Spark executor?

Junior
  1. A.the process that runs tasks and holds cached data
  2. B.a scheduling mode that launches all tasks of a stage together (gang scheduling) for distributed ML workloads like deep learning
  3. C.the point created by a shuffle (wide dependency) that splits a job into stages
  4. D.the recorded chain of transformations used to recompute lost partitions
Reveal the answer + AI explanation — free account

30. Which statement is correct?

Junior
  1. A.Spark executor — the basic unit of parallelism in Spark, a logical chunk of a dataset that one task processes
  2. B.Spark executor — a read-only variable cached on each executor so a large lookup table is shipped once rather than with every task
  3. C.Spark executor — a lazy operation that returns a new RDD/DataFrame without executing (map, filter, join)
  4. D.Spark executor — the process that runs tasks and holds cached data
Reveal the answer + AI explanation — free account

Showing 30 of 75 Spark Core questions — the full set, with answers, explanations and an AI tutor on every question, is inside.

Free to start

Answers, AI explanations, and a scored voice mock interview

Sign up free to check your answers with explanations, ask the AI tutor anything on any question, and take one full AI mock interview — scored like a real panel.

Practice Spark Core free