Skip to content

Commit

Permalink
Minor: log before assert.
Browse files Browse the repository at this point in the history
  • Loading branch information
PhillHenry committed Dec 11, 2023
1 parent f08c72d commit 9d7b3ce
Showing 1 changed file with 1 addition and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -37,14 +37,14 @@ class MergingDataSpec extends SpecPretifier with GivenWhenThen with TableNameFix
)
val partitionToCountAfter =
partitionKeyToCount(spark.read.table(tableName).as[Datum].collect().toSeq)
And(s"the distribution of partition keys to row counts looks like:\n${histogram(partitionToCountAfter, histoColumns)}")
partitionToCountOriginal.foreach { case (key: Long, count: Int) =>
if (key != partitionId) {
count shouldEqual partitionToCountAfter(key)
} else {
count should be < partitionToCountAfter(key)
}
}
And(s"the distribution of partition keys to row counts looks like:\n${histogram(partitionToCountAfter, histoColumns)}")
}
}

Expand Down

0 comments on commit 9d7b3ce

Please sign in to comment.