Designs, develops, and optimizes large-scale batch and real-time data pipelines using PySpark and Python. Responsibilities include lakehouse architecture, Spark performance tuning, data modeling, workflow orchestration, CI/CD, testing, governance, security, monitoring, and data quality. The role requires production-scale distributed computing expertise, cloud platform experience, streaming technologies, and advanced SQL.
We are seeking an experienced and results-driven PySpark / Big Data Engineer to design, develop, and maintain large-scale batch and real-time data pipelines. In this role, you will be responsible for transforming complex raw data into actionable analytical data models, optimizing distributed computing workloads, and ensuring data integrity, scalability, and security across enterprise data platforms.
The ideal candidate possesses deep expertise in Apache Spark architecture, advanced Python programming, distributed systems optimization, modern cloud platforms, and data warehousing/lakehouse paradigms.
Key ResponsibilitiesData Pipeline Design & Development
- Architect, build, and maintain robust, scalable ETL/ELT pipelines using PySpark and Python to ingest data from diverse batch and streaming sources (Kafka, relational databases, REST APIs, Object Storage).
- Design and implement Lakehouse architectures using formats such as Delta Lake, Apache Iceberg, or Apache Hudi.
- Build reusable frameworks and data ingestion libraries to standardize enterprise data processing.
- Diagnose and tune Spark application performance, managing memory allocation, partitions, execution plans, broadcast joins, data skews, and garbage collection.
- Optimize query execution plans using Catalyst Optimizer and Tungsten execution engine.
- Monitor and troubleshoot production Spark jobs across cluster management environments (YARN, Kubernetes, or Databricks).
- Collaborate with Data Architects to design dimensional (Star/Snowflake), normalized, and Data Vault schemas optimized for analytical workloads.
- Ensure efficient data storage, partitioning strategies, and file format selection (Parquet, ORC, Avro).
- Schedule and orchestrate complex workflow DAGs using workflow orchestrators such as Apache Airflow, Prefect, or Dagster.
- Implement CI/CD pipelines (Git, Jenkins, GitLab CI, or GitHub Actions) for automated testing, packaging, and deployment of data pipelines.
- Write unit tests, integration tests, and data validation routines (e.g., Great Expectations, PyTest).
- Implement enterprise data governance, lineage tracking, metadata management, and data quality frameworks.
- Ensure strict compliance with data security, masking, tokenization, RBAC, and regulatory privacy standards (e.g., GDPR, CCPA).
- Core Technologies - Apache Spark, PySpark (Spark SQL, DataFrames, Datasets, Structured Streaming), Python 3.x
- Database & Querying - Advanced SQL, Query optimization, Indexing, Window functions
- Data Lake & Lakehouse - Delta Lake, Apache Iceberg, Apache Hudi, Parquet, Avro, ORC
- Workflow & Orchestration - Apache Airflow, Luigi, Prefect, or Databricks Workflows
- Cloud Platforms - AWS (EMR, Glue, S3, Redshift), Azure (Synapse, ADLS, HDInsight), or GCP (Dataproc, BigQuery, GCS)
- Streaming Technologies - Apache Kafka, Spark Structured Streaming, Event Hubs, or Kinesis
- Distributed Computing Fundamentals: In-depth knowledge of Spark internals (RDD, Catalyst Optimizer, DAG execution, Shuffling, Narrow vs. Wide dependencies).
- Production Experience: Minimum 4+ years of hands-on experience building and deploying production-grade PySpark applications at enterprise scale.
- Problem Solving: Proven track record in debugging memory bottlenecks, Out-Of-Memory (OOM) errors, and resolving data skew issues.
- Data Engineering Best Practices: Experience implementing modular code architectures, logging, monitoring (Prometheus, Grafana, CloudWatch), and alerting.
- Hands-on experience with Databricks platform (Delta Lake, Unity Catalog, Photon engine, MLflow).
- Familiarity with Scala/Java in addition to Python.
- Knowledge of DataOps and Infrastructure as Code (Terraform, CloudFormation).
- Experience with modern analytical data warehouses (Snowflake, Google BigQuery, Amazon Redshift).
- Relevant certifications: Databricks Certified Data Engineer Associate / Professional AWS Certified Data Engineer / Azure Data Engineer Associate (DP-203)CCA Spark and Hadoop Developer (or equivalent)
- Bachelor’s or Master’s degree in Computer Science, Software Engineering, Information Technology, Data Science, or a related quantitative field (or equivalent practical experience).
Primary : Py Spark, Python
Secondary : Bigdata, Abinitio, Unix, Oracle
------------------------------------------------------
Job Family Group: Technology------------------------------------------------------
Job Family:Applications Development------------------------------------------------------
Time Type:Full time------------------------------------------------------
Most Relevant Skills Please see the requirements listed above.------------------------------------------------------
Other Relevant Skills For complementary skills, please see above and/or contact the recruiter.------------------------------------------------------
Citi is an equal opportunity employer, and qualified candidates will receive consideration without regard to their race, color, religion, sex, sexual orientation, gender identity, national origin, disability, status as a protected veteran, or any other characteristic protected by law.
If you are a person with a disability and need a reasonable accommodation to use our search tools and/or apply for a career opportunity review Accessibility at Citi.
View Citi’s EEO Policy Statement and the Know Your Rights poster.
Similar Jobs
Financial Services
Build, test, optimize, and support batch and real-time data pipelines using Spark, Databricks, Kafka, Scala, Python, and SQL. Troubleshoot performance and production issues, develop Iceberg or Delta Lake solutions, analyze execution plans and logs, and maintain reliable Lakehouse architectures. Collaborate with technical teams, participate in testing and deployments, address security and governance requirements, resolve application issues, and provide guidance to junior analysts while delivering work independently within established standards.
Top Skills:
Apache IcebergSparkCloud PlatformsDatabricksDelta LakeIntegration TestingKafkaLakehouse ArchitectureMedallion ArchitectureMonitoringPythonScalaSpark Structured StreamingSQLUnit TestingVersion Control
Information Technology • Consulting • Financial Services
Design, develop, optimize, and maintain scalable ETL pipelines using PySpark and AWS Glue. Build data ingestion and transformation workflows, orchestrate processes with AWS Step Functions, and develop Python-based AWS Lambda functions. Support AWS data lake architectures, analytical use cases, monitoring, reliability, and performance optimization. The role also involves SQL and may include Java microservices, REST APIs, and backend integrations.
Top Skills:
AWSAws Data LakesAws GlueAws LambdaAws Step FunctionsETLJavaPysparkPythonRest ApisSQL
Artificial Intelligence • Big Data • Healthtech • Information Technology • Machine Learning • Software • Analytics
Owns technical product execution for CareSelect Imaging by translating strategy and customer needs into capabilities, features, user stories, acceptance criteria, and prioritized backlogs. Partners with distributed Engineering, Architecture, QA, Product, and Operations teams to manage dependencies, risks, planning, development, testing, releases, and validation. Communicates priorities and delivery status while improving requirements quality and predictability.
Top Skills:
AhaAzure DevopsDevOpsFhirHl7JIRARally
What you need to know about the Chennai Tech Scene
To locals, it's no secret that South India is leading the charge in big data infrastructure. While the environmental impact of data centers has long been a concern, emerging hubs like Chennai are favored by companies seeking ready access to renewable energy resources, which provide more sustainable and cost-effective solutions. As a result, Chennai, along with neighboring Bengaluru and Hyderabad, is poised for significant growth, with a projected 65 percent increase in data center capacity over the next decade.
