in flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/reconciler/diff/DiffResult.java [60:101]
public String toString() {
if (diffList.isEmpty()) {
return "";
}
final StringBuilder builder = new StringBuilder();
builder.append(before.getClass().getSimpleName()).append("[");
diffList.forEach(
diff -> {
try {
JsonNode diffBefore =
objectMapper.readTree(
objectMapper.writeValueAsString(diff.getLeft()));
JsonNode diffAfter =
objectMapper.readTree(
objectMapper.writeValueAsString(diff.getRight()));
JsonNode jsonDiff = JsonDiff.asJson(diffBefore, diffAfter);
jsonDiff.forEach(
row -> {
addField(
builder,
diffBefore,
diffAfter,
diff.getFieldName(),
row);
builder.append(", ");
});
builder.setLength(builder.length() - 2);
} catch (Exception je) {
builder.append(diff.getFieldName())
.append(" : ")
.append(diff.getLeft())
.append(" -> ")
.append(diff.getRight());
}
builder.append(", ");
});
builder.setLength(builder.length() - 2);
builder.append("]");
return String.format("Diff: %s", builder);
}