KPMG Data Engineer Interview Questions (2026)
Prepare for your technical rounds at KPMG with 21+ reported questions across SQL, Apache Spark, Python, and System Design. Compare typical candidate answers against FAANG 9/10 benchmarks, and test your own solutions with instant AI feedback.
Interview Topic Weightage at KPMG
Based on verified interview loopsUnlocked FAANG-Calibrated Answer Rubric (Top 3 Tested Questions)
- •Structured delivery following Problem Formulation -> Execution Plan -> Failure Recovery
- •Concrete parameters: partition keys, join strategies, memory limits, and I/O costs
- •Explicit trade-off evaluation (e.g. storage cost vs query latency, exactly-once overhead)
Complete KPMG Question Vault (18 Questions)
Showing 15 of 18If you already have an offer, why are you exploring other roles?
Situation: I had an offer from Company A. Task: Explain continued exploration professionally. Action: I said I was excited about the offer but wanted to ensure the best long-term fit. I emphasized genuine interest in this role (mission, team, technical challenges). I was transparent about timeline....
Introduce yourself, highlighting key projects and tech stacks
Situation: Opening of technical interview. Task: Concise, impact-focused intro. Action: 'I'm a Senior DE with X years—built real-time (Kafka/Flink) and batch (Spark/Delta) pipelines. Key projects: migration that cut costs 40%, platform that reduced failures 80%. Stack: Python, SQL, Spark, Airflow, dbt, AWS....
Why did you leave your previous job?
My decision to leave my previous position was primarily driven by a desire for new technical challenges and a broader scope of impact that aligns more closely with my long term career aspirations in…
Are you willing to relocate to Bangalore?
**STAR**: Situation: Role may require Bangalore. Task: Evaluate. **Action**: I am open based on role fit, team, and growth. I consider team presence, project impact, and trajectory. I have worked in distributed teams. I ask about timeline and relocation support. **Result**: For the right opportunity, I am flexible....
Count occurrences of a specific word in a file
Counting word occurrences efficiently depends heavily on file size and the execution environment. For small files, command line tools or simple Python scripts suffice. For large, distributed files, a…
Discuss Logical Plan vs Physical Plan
**Logical Plan**: Abstract 'what'—filter, join, aggregate. Independent of execution. Optimizer applies rules (predicate pushdown, constant folding). **Physical Plan**: Concrete 'how'—which join algo (sort-merge, broadcast hash), partitioning, resource allocation. Cost-based choices. **Why Both**: Separation enables optimization without locking to implementation....
Discuss the nature and volume of data you manage daily
**Data Types**: Structured (transactions, dimensions), semi-structured (logs, events). **Volume**: Hundreds of GB to multi-TB. **Sources**: Batch (Airflow), streaming (Kafka). **Stack**: Spark/Databricks, Snowflake/BigQuery, S3/GCS. **Responsibilities**: ETL, schema evolution, data quality, serving for BI/ML....
Explain your day-to-day responsibilities as a Data Engineer
**Responsibilities**: (1) ETL/ELT—batch and streaming; (2) Data modeling—star/snowflake, data vault; (3) Data quality—monitoring, validation, anomaly detection; (4) Support analytics/ML—optimize queries, clean datasets; (5) Collaborate—requirements, reviews, incidents. **Stack**: SQL, Python, Spark, Airflow, cloud. Monitor pipeline health; documentation, lineage, runbooks....
Match countries in a pairwise format
Produce unique pairs (A,B) with A<B. SQL: SELECT a.country c1, b.country c2 FROM countries a CROSS JOIN countries b WHERE a.country < b.country. Python: list(combinations(countries, 2)). Output: N*(N-1)/2 pairs. SCALABILITY: CROSS JOIN is O(n²)—avoid for large n; use sampling or pre-aggregation....
Find the minimum and maximum values in an array
The most efficient way to find the minimum and maximum values in an array is through a single pass iteration, initializing both min and max with the first element and updating them as you traverse the…
Count occurrences of each character in a string
**Architectural Logic**: Character-level operations in SQL vary by engine; choose based on scale and frequency. **PostgreSQL**: `WITH chars AS (SELECT unnest(string_to_array('hello', null)) AS c) SELECT c, COUNT(*) FROM chars GROUP BY c`. **Spark**: `df.select(explode(split(col("str"), "")).alias("c")).groupBy("c").count()`. **BigQuery/Snowflake**: SPLIT, REGEXP_EXTRACT_ALL, or UDF. **Why It Matters**: SQL is not optimized for character iteration; at scale, consider application-layer or UDF....
Alternatives to the Medallion Architecture
**Section 1 — The Context (The 'Why')** The primary challenge for this design in Spark/Big Data is balancing scale, cost, and reliability. At scale, naive approaches fail: single points of failure cause cascades, schema evolution breaks consumers, and over-provisioning explodes cost. Failure modes include silent data loss from non-idempotent writes, cascading job failures from tight coupling, and operational burden from manual intervention....
Compare ORC and Parquet
**Why format choice matters**: Both columnar; ecosystem and tool support differ. **ORC (Hive)**: Columnar; ACID; predicate pushdown; good compression. Strong in Hive ecosystem. **Parquet**: Columnar; schema evolution; ecosystem standard; Spark, Athena, BigQuery native. **Scalability trade-offs**: Parquet = broader connector support; ORC = Hive-native. **Cost implications**: Similar compression; Parquet often faster in Spark/cloud....
Create a DataFrame with default column types
**Example**: ```python from pyspark.sql import SparkSession from pyspark.sql.types import StructType, StructField, StringType, IntegerType schema = StructType([ StructField("id", IntegerType()), StructField("name", StringType()), ]) df = spark.createDataFrame([], schema) # Or DDL: spark.createDataFrame([], "id int, name string") ``` **Why it matters**: Empty DataFrame with schema enables downstream operations without data; used for union, schema validation....
Explain job execution in Spark: stages, tasks, Catalyst Optimizer
**Why it matters**: At scale, design choices directly impact reliability, latency, and cost. Wrong decisions compound across jobs and teams. Spark job execution: (1) Action triggers job; (2) DAG Scheduler creates stages (bounded by shuffle); (3) Task Scheduler launches tasks (one per partition) on executors; (4) Catalyst optimizes logical and physical plans—predicate pushdown, join strategy, partition pruning. Each stage runs as a set of parallel tasks....
Stop Guessing If Your Answers Clear the Bar at KPMG
DataEngPrep’s AI evaluates your real answers against strict FAANG hire rubrics. Check accuracy, optimize shuffle partitions, detect edge case omissions, and receive an instant 9/10 rewrite before stepping into your real interview loop.
Similar Tier Companies Hiring Data Engineers
Explore interview loops with overlapping system design and SQL standards.
Frequently Asked Questions About KPMG Data Engineering Interviews
What topics are asked most frequently in KPMG data engineering interviews?▼
Technical interviews at KPMG heavily emphasize Spark/Big Data and General/Other, accounting for the majority of technical questions in our repository of 21+ verified interview questions. Candidates should expect hands-on rounds testing query optimization, data skew mitigation, and end-to-end pipeline architecture.
How deep do KPMG interviewers go on Apache Spark, SQL, and system design?▼
Interviewers at KPMG probe far beyond syntax. They expect candidates to discuss Spark DAG execution plans, shuffle partitions, join selection strategies (broadcast hash vs shuffle sort-merge), and handling un-even data distributions. In system design, emphasis is placed on fault tolerance, backfilling, and SLA preservation under high data volume.
What is the typical technical interview loop format for Data Engineers at KPMG?▼
The KPMG interview process typically consists of: 1) Initial Recruiter Screen (30 mins), 2) Technical Phone Screen focusing on live SQL and data manipulation (45-60 mins), followed by a 4-5 round Virtual Onsite covering SQL & Coding, Distributed Pipeline Architecture, Data Modeling, and a Behavioral/Bar-Raiser session.
How can I practice KPMG data engineer interview questions with AI feedback?▼
You can practice directly on DataEngPrep.tech. Select any question from the KPMG library, submit your answer, and receive an instant FAANG-calibrated evaluation scored across accuracy, technical depth, communication, and completeness, complete with an interview-ready model answer rewrite.