diff --git a/flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/TableChange.java b/flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/TableChange.java index 5252cf61b031..773b34b6c495 100644 --- a/flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/TableChange.java +++ b/flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/TableChange.java @@ -192,6 +192,8 @@ static class Builder { private long eqDeleteRecordCount = 0L; private int commitCount = 0; + private Builder() {} + public Builder dataFileCount(int newDataFileCount) { this.dataFileCount = newDataFileCount; return this; diff --git a/flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/TableChange.java b/flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/TableChange.java index 5252cf61b031..773b34b6c495 100644 --- a/flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/TableChange.java +++ b/flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/TableChange.java @@ -192,6 +192,8 @@ static class Builder { private long eqDeleteRecordCount = 0L; private int commitCount = 0; + private Builder() {} + public Builder dataFileCount(int newDataFileCount) { this.dataFileCount = newDataFileCount; return this;