12
12
import org .elasticsearch .action .ActionListener ;
13
13
import org .elasticsearch .client .internal .node .NodeClient ;
14
14
import org .elasticsearch .rest .BaseRestHandler ;
15
- import org .elasticsearch .rest .BytesRestResponse ;
16
15
import org .elasticsearch .rest .RestRequest ;
16
+ import org .elasticsearch .rest .RestResponse ;
17
17
import org .elasticsearch .rest .RestStatus ;
18
18
import org .elasticsearch .xcontent .XContentBuilder ;
19
19
import org .elasticsearch .xcontent .XContentParser ;
@@ -50,7 +50,7 @@ public void onResponse(EsqlQueryResponse esqlQueryResponse) {
50
50
try {
51
51
XContentBuilder builder = channel .newBuilder (request .getXContentType (), XContentType .JSON , true );
52
52
esqlQueryResponse .toXContent (builder , request );
53
- channel .sendResponse (new BytesRestResponse (RestStatus .OK , builder ));
53
+ channel .sendResponse (new RestResponse (RestStatus .OK , builder ));
54
54
} catch (Exception e ) {
55
55
onFailure (e );
56
56
}
@@ -59,7 +59,7 @@ public void onResponse(EsqlQueryResponse esqlQueryResponse) {
59
59
@ Override
60
60
public void onFailure (Exception e ) {
61
61
try {
62
- channel .sendResponse (new BytesRestResponse (channel , e ));
62
+ channel .sendResponse (new RestResponse (channel , e ));
63
63
} catch (Exception inner ) {
64
64
inner .addSuppressed (e );
65
65
logger .error ("failed to send failure response" , inner );
0 commit comments