Overwrite the geoparquet output directory to avoid test failures when…

… running with other tests
apache · Oct 30, 2024 · b694360 · b694360
1 parent be98052
commit b694360
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
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
@@ -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
@@ -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 =