We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 9cfe5ab commit 91637dbCopy full SHA for 91637db
core/src/main/java/org/apache/iceberg/PartitionStats.java
@@ -159,10 +159,12 @@ public void appendStats(PartitionStats entry) {
159
this.equalityDeleteRecordCount += entry.equalityDeleteRecordCount;
160
this.equalityDeleteFileCount += entry.equalityDeleteFileCount;
161
162
- if (totalRecordCount == null) {
163
- this.totalRecordCount = entry.totalRecordCount;
164
- } else {
165
- this.totalRecordCount += entry.totalRecordCount;
+ if (entry.totalRecordCount != null) {
+ if (totalRecordCount == null) {
+ this.totalRecordCount = entry.totalRecordCount;
+ } else {
166
+ this.totalRecordCount += entry.totalRecordCount;
167
+ }
168
}
169
170
if (entry.lastUpdatedAt != null) {
0 commit comments