xueyiming 1 mese fa
parent
commit
f78cd91d1f

+ 4 - 4
src/main/scala/com/aliyun/odps/spark/examples/makedata_ad/v20240718/diff_data_20250319.scala

@@ -98,8 +98,8 @@ object diff_data_20250319 {
 
       keys.foreach { key =>
         if (map1.containsKey(key) && map2.containsKey(key)) {
-          val value1 = map1.get(key)
-          val value2 = map2.get(key)
+          val value1 = map1.getString(key)
+          val value2 = map2.getString(key)
 
           def tryToNumber(value: Any): Option[java.lang.Number] = {
             value match {
@@ -122,8 +122,8 @@ object diff_data_20250319 {
                 featureCount(key) = featureCount.getOrElse(key, 0) + 1
               }
             case _ =>
-              val str1 = if (value1 != null) value1.toString else ""
-              val str2 = if (value2 != null) value2.toString else ""
+              val str1 = if (value1 != null) value1 else ""
+              val str2 = if (value2 != null) value2 else ""
               if (str1 != str2) {
                 featureCount(key) = featureCount.getOrElse(key, 0) + 1
               }