xueyiming преди 1 месец
родител
ревизия
cc7d946a5b
променени са 1 файла, в които са добавени 2 реда и са изтрити 2 реда
  1. 2 2
      src/main/scala/com/aliyun/odps/spark/examples/makedata_ad/v20240718/diff_data_20250319.scala

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

@@ -122,8 +122,8 @@ object diff_data_20250319 {
                 featureCount(key) = featureCount.getOrElse(key, 0) + 1
               }
             case _ =>
-              val str1 = value1.toString
-              val str2 = value2.toString
+              val str1 = if (value1 != null) value1.toString else ""
+              val str2 = if (value2 != null) value2.toString else ""
               if (str1 != str2) {
                 featureCount(key) = featureCount.getOrElse(key, 0) + 1
               }