Skip to content

Commit d524937

Browse files
committed
Compile fix
1 parent 7a8cc33 commit d524937

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

python/pyspark/sql/avro/functions.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -60,7 +60,7 @@ def from_avro(col, jsonFormatSchema, options={}):
6060
_to_java_column(col), jsonFormatSchema, options)
6161
except TypeError as e:
6262
if str(e) == "'JavaPackage' object is not callable":
63-
_print_missing_jar("Avro", "avro", "avro", ssc.sparkContext.version)
63+
_print_missing_jar("Avro", "avro", "avro", sc.version)
6464
raise
6565
return Column(jc)
6666

@@ -88,7 +88,7 @@ def to_avro(col):
8888
jc = sc._jvm.org.apache.spark.sql.avro.functions.to_avro(_to_java_column(col))
8989
except TypeError as e:
9090
if str(e) == "'JavaPackage' object is not callable":
91-
_print_missing_jar("Avro", "avro", "avro", ssc.sparkContext.version)
91+
_print_missing_jar("Avro", "avro", "avro", sc.version)
9292
raise
9393
return Column(jc)
9494

0 commit comments

Comments
 (0)