Update medium-stats-spark-driver.py

pavan-kumar-99 · Jun 10, 2024 · 43e52e8 · 43e52e8
1 parent 1aef60d
commit 43e52e8
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/scripts/medium/medium-stats-spark-driver.py b/scripts/medium/medium-stats-spark-driver.py
@@ -193,7 +193,8 @@ def compute_yearly_statistics(spark, table_name):
         help="Ingestion mode: append or create",
     )
     args = parser.parse_args()
-
+
+    catalog_name = "medium_stats"
     db_name = "mediumstats"
     table_name = "articles"
     local_path = "/usr/stats/" + args.key