do not repartition when source dataframe has the same partition numbe…

…r with write partition config (vesoft-inc#173)
Nicole00 · Nov 27, 2023 · 9479d2d · 9479d2d
1 parent c2d7aa3
commit 9479d2d
Showing 1 changed file with 0 additions and 1 deletion.
diff --git a/nebula-exchange_spark_2.2/src/main/scala/com/vesoft/nebula/exchange/Exchange.scala b/nebula-exchange_spark_2.2/src/main/scala/com/vesoft/nebula/exchange/Exchange.scala
@@ -289,7 +289,6 @@ object Exchange {
         }
     }
 
-
     // reimport for failed tags and edges
     val errorPath = s"${configs.errorConfig.errorPath}/${SparkEnv.get.blockManager.conf.getAppId}"
     if (failures > 0 && ErrorHandler.existError(errorPath)) {