Removed RMD size from the record too large check, so it's not counted…

… towards the `maxRecordSizeBytes` record size limit. 🔦
linkedin · Jul 29, 2024 · 16634a0 · 16634a0
1 parent 2fca171
commit 16634a0
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/internal/venice-common/src/main/java/com/linkedin/venice/writer/VeniceWriter.java b/internal/venice-common/src/main/java/com/linkedin/venice/writer/VeniceWriter.java
@@ -907,7 +907,8 @@ public CompletableFuture<PubSubProduceResult> put(
      */
     int veniceRecordSize = serializedKey.length + serializedValue.length + replicationMetadataPayloadSize;
     if (isChunkingNeededForRecord(veniceRecordSize)) { // ~1MB default
-      if (isChunkingEnabled && !isRecordTooLarge(veniceRecordSize)) {
+      // RMD size is not checked because it's an internal component, and a user's write should not be failed due to it
+      if (isChunkingEnabled && !isRecordTooLarge(serializedKey.length + serializedValue.length)) {
         return putLargeValue(
             serializedKey,
             serializedValue,