From 149d84b8329f753ef79449d1008f2fa46155756c Mon Sep 17 00:00:00 2001
From: Aigul9 <46625461+Aigul9@users.noreply.github.com>
Date: Wed, 6 Dec 2023 15:59:54 +0300
Subject: [PATCH] fix ratio in constraint_message

---
 .../com/amazon/deequ/comparison/ReferentialIntegrity.scala      | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/src/main/scala/com/amazon/deequ/comparison/ReferentialIntegrity.scala b/src/main/scala/com/amazon/deequ/comparison/ReferentialIntegrity.scala
index 5de620d33..45c49cc76 100644
--- a/src/main/scala/com/amazon/deequ/comparison/ReferentialIntegrity.scala
+++ b/src/main/scala/com/amazon/deequ/comparison/ReferentialIntegrity.scala
@@ -60,7 +60,7 @@ object ReferentialIntegrity extends ComparisonBase {
       val referenceSparkCols = reference.select(referenceColumns.map(col): _*)
       val mismatchCount = primarySparkCols.except(referenceSparkCols).count()
 
-      val ratio = if (mismatchCount == 0) 1.0 else (primaryCount - mismatchCount).toDouble / primaryCount
+      val ratio = mismatchCount.toDouble / primaryCount
 
       if (assertion(ratio)) {
         ComparisonSucceeded()