wip

ldbc · Aug 23, 2024 · ab14b81 · ab14b81
1 parent 69caa03
commit ab14b81
Showing 1 changed file with 0 additions and 8 deletions.
diff --git a/src/main/scala/ldbc/finbench/datagen/generation/serializers/ActivitySerializer.scala b/src/main/scala/ldbc/finbench/datagen/generation/serializers/ActivitySerializer.scala
@@ -341,10 +341,6 @@ class ActivitySerializer(sink: RawSink)(implicit spark: SparkSession)
     val futures = Seq(
       SparkUI.jobAsync("Write person invest", "Write Person Invest") {
         val rawPersonInvestCompany = investedCompaniesRDD.flatMap { c =>
-          log.info(
-            "[Invest] Company " + c.getCompanyId + ", PersonInvestCompanies count: " +
-              c.getPersonInvestCompanies.size()
-          )
           c.getPersonInvestCompanies.asScala.map { pic =>
             PersonInvestCompanyRaw(
               pic.getPerson.getPersonId,
@@ -368,10 +364,6 @@ class ActivitySerializer(sink: RawSink)(implicit spark: SparkSession)
       },
       SparkUI.jobAsync("Write company invest", "Write Company Invest") {
         val rawCompanyInvestCompany = investedCompaniesRDD.flatMap { c =>
-          log.info(
-            "[Invest] Company " + c.getCompanyId + ", CompanyInvestCompanies count: " +
-              c.getCompanyInvestCompanies.size()
-          )
           c.getCompanyInvestCompanies.asScala.map { cic =>
             CompanyInvestCompanyRaw(
               cic.getFromCompany.getCompanyId,