Question 1

Could you describe a specific cost optimization strategy you implemented in the cloud and its results?

Accepted Answer

Situation: BigQuery costs spiked 40% in a quarter; ad-hoc queries and unoptimized scans dominated spend. Task: Reduce spend without constraining analysts or degrading UX. Action: I led a cost optimization initiative: (1) Partitioned and clustered high-cardinality columns—event_date, user_id—to cut bytes scanned by ~50%; (2) Implemented slot reservations for predictable workloads; (3) Added query cost attribution via labels and alerts for queries exceeding $50; (4) Created materialized views for...

Question 2

How Airflow operates in a Kubernetes environment

Accepted Answer

Architectural logic: KubernetesExecutor runs each task in its own pod. Scheduler creates pod → task runs → pod terminates. Isolation and per-task resource control. DAGs in shared volume or Git-sync. Example: Helm deploys scheduler, workers, webserver; task runs spark-submit in pod....

Question 3

How Airflow stores logs and the role of its backend database

Accepted Answer

Architectural split: Logs = filesystem or remote (S3/GCS); default logs/dag_id/task_id/date/. Database = metadata (DAGs, runs, task instances, connections)—Postgres/MySQL. Logs not in DB. Best practice: Remote storage (S3/GCS) for logs; retention policy; backup DB; size for DAG volume.

Question 4

How did you contribute to cost optimization initiatives while working with cloud technologies?

Accepted Answer

Situation: Cloud spend grew with adoption. Task: Reduce cost without impacting delivery. Action: (1) Right-sized EC2 and EMR. (2) Reserved Instances for baseline. (3) S3 lifecycle and Intelligent-Tiering. (4) Stopped non-prod outside hours. (5) Tagging and chargeback. (6) Query optimization (Athena, Redshift). Result: ~30% cost reduction....

Question 5

Write code to upload Parquet files to an S3 bucket using boto3

Accepted Answer

**Simple**: s3.upload_file('data.parquet', 'my-bucket', 'path/data.parquet')—handles multipart for >8MB. **From DataFrame**: df.to_parquet('s3://bucket/path/', engine='pyarrow') with s3fs. **Programmatic**: pyarrow read_table, write to BytesIO, s3.put_object(Body=buffer.getvalue()). **Large files**: upload_file does multipart automatically; for >5GB, configure multipart threshold. **Encryption**: put_object(ServerSideEncryption='aws:kms')....

Walmart Cloud & Tools Interview Questions

Companies asking these questions

All 5 Questions

More Interview Prep Guides

Get All Answers in PDF Format

Walmart Cloud & Tools Interview Questions

Companies asking these questions

All 5 Questions

More Interview Prep Guides

Get All Answers in PDF Format