delay

Author: Tim-Brooks

server/src/main/java/org/elasticsearch/action/index/IndexRequest.java

@@ -973,7 +973,11 @@ public int route(IndexRouting indexRouting) {
         if (modernSource.isStructured()) {
             // TODO: Need to implement filtering
             // return indexRouting.indexShard(id, routing, contentType, structuredSource);
-            return indexRouting.indexShard(id, routing, contentType, source());
+            if (indexRouting instanceof IndexRouting.ExtractFromSource) {
+                return indexRouting.indexShard(id, routing, contentType, source());
+            } else {
+                return indexRouting.indexShard(id, routing, contentType, (BytesReference) null);
+            }
         } else {
             return indexRouting.indexShard(id, routing, contentType, source());
         }