Skip to content

Commit fa5a1cf

Browse files
committed
fix to_avro function
1 parent f9ecebd commit fa5a1cf

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

connector/avro/src/test/scala/org/apache/spark/sql/avro/AvroSuite.scala

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -25,7 +25,7 @@ import java.util.UUID
2525

2626
import scala.jdk.CollectionConverters._
2727

28-
import org.apache.avro.{AvroTypeException, Schema, SchemaBuilder, SchemaFormatter}
28+
import org.apache.avro.{Schema, SchemaBuilder, SchemaFormatter}
2929
import org.apache.avro.Schema.{Field, Type}
3030
import org.apache.avro.Schema.Type._
3131
import org.apache.avro.file.{DataFileReader, DataFileWriter}
@@ -1380,7 +1380,7 @@ abstract class AvroSuite
13801380

13811381
checkError(
13821382
exception = intercept[SparkRuntimeException] {
1383-
df.select(to_avro($"outerStruct", avroTypeStruct)).collect()
1383+
df.select(avro.functions.to_avro($"outerStruct", avroTypeStruct)).collect()
13841384
},
13851385
condition = "AVRO_CANNOT_WRITE_NULL_FIELD",
13861386
parameters = Map(

0 commit comments

Comments
 (0)