diff --git a/spark/spark-3.4/src/test/scala/org/apache/sedona/sql/geoparquetIOTests.scala b/spark/spark-3.4/src/test/scala/org/apache/sedona/sql/geoparquetIOTests.scala index d8aed36fce..f5bd8b486e 100644 --- a/spark/spark-3.4/src/test/scala/org/apache/sedona/sql/geoparquetIOTests.scala +++ b/spark/spark-3.4/src/test/scala/org/apache/sedona/sql/geoparquetIOTests.scala @@ -746,7 +746,7 @@ class geoparquetIOTests extends TestBaseScala with BeforeAndAfterAll { val df = sparkSession .createDataFrame(sparkSession.sparkContext.parallelize(data), schema) .withColumn("geom", expr("ST_Point(id, id)")) - df.write.format("geoparquet").save(geoparquetoutputlocation) + df.write.format("geoparquet").mode("overwrite").save(geoparquetoutputlocation) // Read it back val df2 = diff --git a/spark/spark-3.5/src/test/scala/org/apache/sedona/sql/geoparquetIOTests.scala b/spark/spark-3.5/src/test/scala/org/apache/sedona/sql/geoparquetIOTests.scala index 732920ae69..a6e74730a0 100644 --- a/spark/spark-3.5/src/test/scala/org/apache/sedona/sql/geoparquetIOTests.scala +++ b/spark/spark-3.5/src/test/scala/org/apache/sedona/sql/geoparquetIOTests.scala @@ -749,7 +749,7 @@ class geoparquetIOTests extends TestBaseScala with BeforeAndAfterAll { val df = sparkSession .createDataFrame(sparkSession.sparkContext.parallelize(data), schema) .withColumn("geom", expr("ST_Point(id, id)")) - df.write.format("geoparquet").save(geoparquetoutputlocation) + df.write.format("geoparquet").mode("overwrite").save(geoparquetoutputlocation) // Read it back val df2 =