Fix

Author: Tim-Brooks

server/src/main/java/org/elasticsearch/action/bulk/TransportShardBulkAction.java

@@ -741,7 +741,7 @@ private static Engine.Result performOpOnReplica(
                 final IndexRequest indexRequest = (IndexRequest) docWriteRequest;
                 final SourceToParse sourceToParse = new SourceToParse(
                     indexRequest.id(),
-                    indexRequest.source(),
+                    indexRequest.modernSource(),
                     indexRequest.getContentType(),
                     indexRequest.routing()
                 );

server/src/main/java/org/elasticsearch/index/mapper/SourceToParse.java

@@ -80,6 +80,10 @@ public SourceToParse(String id, BytesReference source, XContentType xContentType
         this(id, source, xContentType, routing, Map.of(), true, XContentMeteringParserDecorator.NOOP);
     }
 
+    public SourceToParse(String id, ModernSource source, XContentType xContentType, String routing) {
+        this(id, source, xContentType, routing, Map.of(), true, XContentMeteringParserDecorator.NOOP);
+    }
+
     public SourceToParse(
         String id,
         BytesReference source,