All Stories

How to Speed Up AWS Athena Queries Using Partition Projection

How to define partition projection while creating an Athena table
Bartosz Mikulski
30 Aug 2020

How to send a customized Slack notification when an Airflow task fails

How to customize a Slack notification before sending it to the Slack incoming webhook.
Bartosz Mikulski
27 Aug 2020

How to use one SparkSession to run all Pytest tests

How to speed us Pytest tests by reusing the same SparkSession in all of them
Bartosz Mikulski
20 Jul 2020

How to send AWS CloudWatch Alerts to a Slack channel using Terraform

How to use Terraform to configure a CloudWatch alert and send the message to a Slack channel.
Bartosz Mikulski
13 Jul 2020

Check-Engine - data quality validation for PySpark 3.0.0

Last week, I was testing whether we can use AWS Deequ for data quality validation. I ran into a few problems. First of all, it was using an outdated version...
Bartosz Mikulski
06 Jul 2020

Measuring data quality using AWS Deequ

How to measure data quality in Athena tables using AWS Deequ running on an EMR cluster.
Bartosz Mikulski
29 Jun 2020

How to conditionally skip tasks in an Airflow DAG

How to use XCom and PythonSensor to skip remaining tasks in an Airflow DAG.
Bartosz Mikulski
22 Jun 2020

The problem with software testing in data engineering

What if we found a bug in our data pipelines? What if that bug were easy to fix, but it would require a lot of time spent backfilling the data?...
Bartosz Mikulski
15 Jun 2020

How does Kafka Connect work?

In this article, I am going to describe the internals of Kafka Connect, explain how it uses the Sink and Source Connectors, and how it tracks the offsets of the...
Bartosz Mikulski
08 Jun 2020

Why my Airflow tasks got stuck in "no_status" and how I fixed it

A story about debugging an Airflow DAG that was not starting tasks
Bartosz Mikulski
01 Jun 2020

What is Kafka log compaction, and how does it work?

How the log compaction is implemented in Apache Kafka and how to configure it properly
Bartosz Mikulski
22 May 2020

How does a Kafka Cluster work?

What is the difference between a leader and a replica broker? What is the cluster controller? How is the controller elected?
Bartosz Mikulski
18 May 2020
About me | Newsletter