diff --git a/spark/src/main/scala/ai/chronon/spark/JoinUtils.scala b/spark/src/main/scala/ai/chronon/spark/JoinUtils.scala index dec60b30b..0f02dc622 100644 --- a/spark/src/main/scala/ai/chronon/spark/JoinUtils.scala +++ b/spark/src/main/scala/ai/chronon/spark/JoinUtils.scala @@ -293,7 +293,7 @@ object JoinUtils { val rightBloomMap = joinPart.rightToLeft.mapValues(leftBlooms(_)).toMap val bloomSizes = rightBloomMap.map { case (col, bloom) => s"$col -> ${bloom.bitSize()}" }.pretty println(s""" - |JoinPart Info: + Generating bloom filter for joinPart: | part name : ${joinPart.groupBy.metaData.name}, | left type : ${joinConf.left.dataModel}, | right type: ${joinPart.groupBy.dataModel},