Skip to content

Commit

Permalink
updated spark_parquet_to_avro.py
Browse files Browse the repository at this point in the history
  • Loading branch information
HariSekhon committed May 6, 2023
1 parent 7fb4da4 commit 86727ce
Showing 1 changed file with 1 addition and 0 deletions.
1 change: 1 addition & 0 deletions spark_parquet_to_avro.py
Original file line number Diff line number Diff line change
Expand Up @@ -52,6 +52,7 @@
os.environ['PYSPARK_SUBMIT_ARGS'] = '--packages com.databricks:spark-avro_2.10:2.0.1 %s' \
% os.getenv('PYSPARK_SUBMIT_ARGS', '')
pyspark_path()
# pylint: disable=import-outside-toplevel
from pyspark import SparkContext # pylint: disable=wrong-import-position,import-error
from pyspark import SparkConf # pylint: disable=wrong-import-position,import-error
from pyspark.sql import SQLContext # pylint: disable=wrong-import-position,import-error
Expand Down

0 comments on commit 86727ce

Please sign in to comment.