|
@@ -79,7 +79,7 @@ public class FeatureDiff {
|
|
}
|
|
}
|
|
|
|
|
|
long diffCount =
|
|
long diffCount =
|
|
- fieldValues.repartition(partitionNum).sample(false, 0.001d).filter(new Function<Map<String, String>,
|
|
|
|
|
|
+ fieldValues.repartition(partitionNum).filter(new Function<Map<String, String>,
|
|
Boolean>() {
|
|
Boolean>() {
|
|
@Override
|
|
@Override
|
|
public Boolean call(Map<String, String> map) throws Exception {
|
|
public Boolean call(Map<String, String> map) throws Exception {
|
|
@@ -100,14 +100,11 @@ public class FeatureDiff {
|
|
|
|
|
|
|
|
|
|
if (offline.size() != online.size()) {
|
|
if (offline.size() != online.size()) {
|
|
- log.info("size diff");
|
|
|
|
return true;
|
|
return true;
|
|
}
|
|
}
|
|
|
|
|
|
for (Map.Entry<String, String> offlineE : offline.entrySet()) {
|
|
for (Map.Entry<String, String> offlineE : offline.entrySet()) {
|
|
if (!StringUtils.equals(online.get(offlineE.getKey()), offlineE.getValue())) {
|
|
if (!StringUtils.equals(online.get(offlineE.getKey()), offlineE.getValue())) {
|
|
- log.info("offline {}, online {}", JSONUtils.toJson(offline),
|
|
|
|
- JSONUtils.toJson(online));
|
|
|
|
return true;
|
|
return true;
|
|
}
|
|
}
|
|
}
|
|
}
|