diff --git a/backend/src/main/java/com/bakdata/conquery/models/messages/namespaces/specific/ReportConsistency.java b/backend/src/main/java/com/bakdata/conquery/models/messages/namespaces/specific/ReportConsistency.java index 6d1425e3ed..b7987596c1 100644 --- a/backend/src/main/java/com/bakdata/conquery/models/messages/namespaces/specific/ReportConsistency.java +++ b/backend/src/main/java/com/bakdata/conquery/models/messages/namespaces/specific/ReportConsistency.java @@ -14,9 +14,7 @@ import com.bakdata.conquery.models.messages.namespaces.NamespacedMessage; import com.bakdata.conquery.models.worker.DistributedNamespace; import com.google.common.collect.Sets; -import lombok.AllArgsConstructor; -import lombok.Data; -import lombok.NonNull; +import lombok.*; import lombok.extern.slf4j.Slf4j; /** @@ -26,13 +24,16 @@ */ @CPSType(id = "REPORT_CONSISTENCY", base = NamespacedMessage.class) @Data +@EqualsAndHashCode(callSuper = false) @AllArgsConstructor @Slf4j public class ReportConsistency extends NamespaceMessage { private WorkerId workerId; // Set default here because an empty set send by the worker is not set (it is null) after deserialization + @ToString.Exclude private Set workerImports = Set.of(); + @ToString.Exclude private Set workerBuckets = Set.of();