add sudo

Signed-off-by: zenghua <[email protected]>
Ceng23333 · Feb 18, 2024 · 39cc8a5 · 39cc8a5
1 parent 1663ed2
commit 39cc8a5
Showing 1 changed file with 10 additions and 10 deletions.
diff --git a/lakesoul-spark/src/test/scala/org/apache/spark/sql/lakesoul/benchmark/ConsistencyCI.scala b/lakesoul-spark/src/test/scala/org/apache/spark/sql/lakesoul/benchmark/ConsistencyCI.scala
@@ -151,16 +151,16 @@ object ConsistencyCI {
       sparkDF.show
       println(s"${tup._1} rustDF: ")
       rustDF.show
-      //      val diff1 = sparkDF.rdd.subtract(rustDF.rdd)
-      //      val diff2 = rustDF.rdd.subtract(sparkDF.rdd)
-      //      val result = diff1.count() == 0 && diff2.count() == 0
-      //      if (!result) {
-      //        println("sparkDF: ")
-      //        println(sparkDF.collectAsList())
-      //        println("rustDF: ")
-      //        println(rustDF.collectAsList())
-      //        System.exit(1)
-      //      }
+      val diff1 = sparkDF.rdd.subtract(rustDF.rdd)
+      val diff2 = rustDF.rdd.subtract(sparkDF.rdd)
+      val result = diff1.count() == 0 && diff2.count() == 0
+      if (!result) {
+        println("sparkDF: ")
+        println(sparkDF.collectAsList())
+        println("rustDF: ")
+        println(rustDF.collectAsList())
+        System.exit(1)
+      }
     })
 
   }