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 index aee243de6..bfe598155 100644 --- 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) + } }) }