diff --git a/spark/src/main/scala/ai/chronon/spark/JoinBase.scala b/spark/src/main/scala/ai/chronon/spark/JoinBase.scala index f59536087..e6fdafec7 100644 --- a/spark/src/main/scala/ai/chronon/spark/JoinBase.scala +++ b/spark/src/main/scala/ai/chronon/spark/JoinBase.scala @@ -361,7 +361,8 @@ abstract class JoinBase(joinConf: api.Join, // set autoExpand = true to ensure backward compatibility due to column ordering changes val finalDf = computeRange(leftDfInRange, range, bootstrapInfo) if (selectedJoinParts.isDefined) { - assert(finalDf.isEmpty, "The arg `selectedJoinParts` is defined, so no final join is required. `finalDf` should be empty") + assert(finalDf.isEmpty, + "The arg `selectedJoinParts` is defined, so no final join is required. `finalDf` should be empty") logger.info(s"Skipping writing to the output table for range: ${range.toString} $progress") return None } else {