Skip to content

Commit d50e3c7

Browse files
committed
Fix
1 parent 6413013 commit d50e3c7

File tree

2 files changed

+5
-2
lines changed

2 files changed

+5
-2
lines changed

server/src/main/java/org/elasticsearch/action/search/SearchQueryThenFetchAsyncAction.java

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -869,7 +869,10 @@ void onShardDone() {
869869
}
870870
}
871871

872-
ActionListener.respondAndRelease(channelListener, new BytesTransportResponse(out.moveToBytesReference()));
872+
ActionListener.respondAndRelease(
873+
channelListener,
874+
new BytesTransportResponse(out.moveToBytesReference(), out.getTransportVersion())
875+
);
873876
}
874877

875878
// Writes the "successful" response (see NodeQueryResponse for the corresponding read logic)

server/src/main/java/org/elasticsearch/search/SearchService.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -296,7 +296,7 @@ public class SearchService extends AbstractLifecycleComponent implements IndexEv
296296
Setting.Property.NodeScope
297297
);
298298

299-
private static final boolean BATCHED_QUERY_PHASE_FEATURE_FLAG = new FeatureFlag("batched_query_phase").isEnabled();
299+
public static final boolean BATCHED_QUERY_PHASE_FEATURE_FLAG = new FeatureFlag("batched_query_phase").isEnabled();
300300

301301
/**
302302
* The size of the buffer used for memory accounting.

0 commit comments

Comments
 (0)