remove the outout path when starting

This commit is contained in:
Claudio Atzori 2020-05-15 22:34:19 +02:00
parent 7838f2c63f
commit ef9a9a9f1a
1 changed files with 1 additions and 3 deletions

View File

@ -53,9 +53,7 @@ public class PrepareResultCommunitySetStep2 {
conf,
isSparkSessionManaged,
spark -> {
if (isTest(parser)) {
removeOutputDir(spark, outputPath);
}
removeOutputDir(spark, outputPath);
mergeInfo(spark, inputPath, outputPath);
});
}