|
@@ -62,7 +62,7 @@ object diff_data_20240718 {
|
|
|
if (key != "logkey" && map2.contains(key) && value1 != map2(key)) {
|
|
|
val res = s"LogKey: $logkey, Key: $key, RDD1 Value: $value1, RDD2 Value: ${map2(key)}"
|
|
|
println(res)
|
|
|
- result += res
|
|
|
+ result = result :+ res
|
|
|
}
|
|
|
}
|
|
|
}
|
|
@@ -72,7 +72,7 @@ object diff_data_20240718 {
|
|
|
rdd1Only.foreach { case (logkey, map) =>
|
|
|
val res = s"LogKey: $logkey, Map only exists in RDD1: $map"
|
|
|
println(res)
|
|
|
- result += res
|
|
|
+ result = result :+ res
|
|
|
}
|
|
|
|
|
|
// 检查 rdd2 中存在但 rdd1 中不存在的 logkey
|
|
@@ -80,7 +80,7 @@ object diff_data_20240718 {
|
|
|
rdd2Only.foreach { case (logkey, map) =>
|
|
|
val res = s"LogKey: $logkey, Map only exists in RDD2: $map"
|
|
|
println(res)
|
|
|
- result += res
|
|
|
+ result = result :+ res
|
|
|
}
|
|
|
|
|
|
val rdd = sc.parallelize(result)
|