From ab14b8174e35917377f5e2b190f949a46c67c922 Mon Sep 17 00:00:00 2001 From: qishipengqsp Date: Fri, 23 Aug 2024 20:38:10 +0800 Subject: [PATCH] wip --- .../generation/serializers/ActivitySerializer.scala | 8 -------- 1 file changed, 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 index 57ebe933..1cc79c12 100644 --- 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,