Merge pull request #348 from ldbc/fix-outputdir

szarnyasg · web-flow · commit eaeb043e5bf5 · 2021-12-12T21:51:11.000+01:00
diff --git a/src/main/scala/ldbc/snb/datagen/spark/LdbcDatagen.scala b/src/main/scala/ldbc/snb/datagen/spark/LdbcDatagen.scala
@@ -140,7 +140,7 @@ object LdbcDatagen extends SparkApp {
     GenerationStage.run(generatorArgs, generatorConfig)
 
     if (args.generateFactors) {
-      val factorArgs = FactorGenerationStage.Args()
+      val factorArgs = FactorGenerationStage.Args(outputDir = args.outputDir)
       FactorGenerationStage.run(factorArgs)
     }
 

Original file line number	Diff line number	Diff line change
`@@ -140,7 +140,7 @@ object LdbcDatagen extends SparkApp {`
`140`	`140`	`GenerationStage.run(generatorArgs, generatorConfig)`
`141`	`141`
`142`	`142`	`if (args.generateFactors) {`
`143`		`- val factorArgs = FactorGenerationStage.Args()`
	`143`	`+ val factorArgs = FactorGenerationStage.Args(outputDir = args.outputDir)`
`144`	`144`	`FactorGenerationStage.run(factorArgs)`
`145`	`145`	`}`
`146`	`146`