test

Signed-off-by: ChenYunHey <1908166778@qq.com>
lakesoul-io · Mar 28, 2024 · f0c51a9 · f0c51a9
1 parent 69ab76b
commit f0c51a9
Showing 1 changed file with 2 additions and 8 deletions.
diff --git a/lakesoul-spark/src/test/scala/org/apache/spark/sql/lakesoul/benchmark/Benchmark.scala b/lakesoul-spark/src/test/scala/org/apache/spark/sql/lakesoul/benchmark/Benchmark.scala
@@ -155,19 +155,13 @@ object Benchmark {
 
     val diff1 = jdbcDF.rdd.subtract(lakesoulDF.rdd)
     val diff2 = lakesoulDF.rdd.subtract(jdbcDF.rdd)
-    println("*******************jdbcDF count"+jdbcDF.count()+"***************")
-    println("*******************jdbcDF count"+lakesoulDF.count()+"***************")
-    println("*********diff1.count:"+diff1.count()+"*******")
-    println("*********diff1.count:"+diff2.count()+"*******")
-    println("jdbcDF schema"+jdbcDF.printSchema())
-    println("lakesoulDF schema"+lakesoulDF.printSchema())
 
     val result = diff1.count() == 0 && diff2.count() == 0
     if (!result) {
       println(printLine + table + " result: " + result + printLine)
-      println("*************diff1**************")
+      println("*************diff1**************"+"dfff1.count:"+diff1.count()+"schema"+jdbcDF.printSchema()+"jdbcDF count:"+jdbcDF.count())
       spark.createDataFrame(diff1, lakesoulDF.schema).show()
-      println("*************diff2**************")
+      println("*************diff2**************"+"diff2.count:"+diff2.count()+"schema"+lakesoulDF.printSchema()+"lakesoulDF count:"+lakesoulDF.count())
       spark.createDataFrame(diff2, lakesoulDF.schema).show()
       println(table + " data verification ERROR!!!")
       System.exit(1)