diff --git a/data_generator/requirements.txt b/data_generator/requirements.txt
index 9b52b40..1e19ee9 100644
--- a/data_generator/requirements.txt
+++ b/data_generator/requirements.txt
@@ -1,2 +1,2 @@
-pyspark==2.4.5
+pyspark==3.2.2
 pika==1.1.0