iter

martijnvg · martijnvg · commit a742ff1ec28f · 2025-09-01T16:39:15.000+02:00
diff --git a/server/src/main/java/org/elasticsearch/search/lookup/ConcurrentSegmentSourceProvider.java b/server/src/main/java/org/elasticsearch/search/lookup/ConcurrentSegmentSourceProvider.java
@@ -74,7 +74,6 @@ public Source getSource(LeafReaderContext ctx, int doc) throws IOException {
 
     @Override
     public SourceProvider optimizedSourceProvider(SourceFilter sourceFilter) {
-        assert leaves.isEmpty() : "source provider must be unused when applying filter";
         if (isStoredSource) {
             return this;
         } else {
diff --git a/x-pack/plugin/esql/src/main/java/org/elasticsearch/xpack/esql/plugin/ReinitializingSourceProvider.java b/x-pack/plugin/esql/src/main/java/org/elasticsearch/xpack/esql/plugin/ReinitializingSourceProvider.java
@@ -54,7 +54,6 @@ public Source getSource(LeafReaderContext ctx, int doc) throws IOException {
 
     @Override
     public SourceProvider optimizedSourceProvider(SourceFilter sourceFilter) {
-        assert perThreadProvider == null : "source provider must be unused when applying filter";
         return new ReinitializingSourceProvider(sourceFilter, sourceProviderFactory);
     }
 

Original file line number	Diff line number	Diff line change
`@@ -54,7 +54,6 @@ public Source getSource(LeafReaderContext ctx, int doc) throws IOException {`
`54`	`54`
`55`	`55`	`@Override`
`56`	`56`	`public SourceProvider optimizedSourceProvider(SourceFilter sourceFilter) {`
`57`		`- assert perThreadProvider == null : "source provider must be unused when applying filter";`
`58`	`57`	`return new ReinitializingSourceProvider(sourceFilter, sourceProviderFactory);`
`59`	`58`	`}`
`60`	`59`