biq query connector changed

lalelisealstad · Sep 28, 2024 · f6ddae8 · f6ddae8
1 parent 22c52b5
commit f6ddae8
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/main.py b/main.py
@@ -4,7 +4,7 @@
 
 def main():
     # Path to the BigQuery connector JAR
-    bigquery_connector_path = 'spark-3.1-bigquery-0.41.0.jar'
+    bigquery_connector_path = 'gs://spark-lib/bigquery/spark-bigquery-latest.jar'
 
     # Start a PySpark session with BigQuery connector
     spark = SparkSession.builder \