diff --git a/fe/fe-core/src/main/java/org/apache/doris/qe/cache/RowBatchBuilder.java b/fe/fe-core/src/main/java/org/apache/doris/qe/cache/RowBatchBuilder.java
index c468bac4be..4f8b832dd6 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/qe/cache/RowBatchBuilder.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/qe/cache/RowBatchBuilder.java
@@ -167,13 +167,17 @@ public class RowBatchBuilder {
             Long key = entry.getKey();
             PartitionRange.PartitionSingle partition = cachePartMap.get(key);
             partitionRowList = entry.getValue();
+            int data_size = 0;
+            for (byte[] buf : partitionRowList) {
+                data_size += buf.length;
+            }
             updateRequest = updateRequest.toBuilder()
                     .addValues(InternalService.PCacheValue.newBuilder()
                             .setParam(InternalService.PCacheParam.newBuilder()
                                     .setPartitionKey(key)
                                     .setLastVersion(partition.getPartition().getVisibleVersion())
                                     .setLastVersionTime(partition.getPartition().getVisibleVersionTime())
-                                    .build()).addAllRows(
+                                    .build()).setDataSize(dataSize).addAllRows(
                                     partitionRowList.stream().map(row -> ByteString.copyFrom(row))
                                             .collect(Collectors.toList()))).build();
         }