github-mirrors/elasticsearch
1
0
Fork 0
mirror of https://github.com/elastic/elasticsearch.git synced 2025-07-06 05:43:52 -04:00
Code Issues Projects Releases Packages Wiki Activity

Fix spotless in netty stream class

Browse source 
Spotless broke during a rebase. Fixing in this commit.
This commit is contained in:
Tim Brooks 2024-09-18 13:55:08 -06:00
parent 92daeeba11
commit 529d349a25
2 changed files with 1 additions and 2 deletions
Download patch file Download diff file Expand all files Collapse all files

1
modules/transport-netty4/src/main/java/org/elasticsearch/http/netty4/Netty4HttpRequestBodyStream.java
View file

@ -40,7 +40,6 @@ public class Netty4HttpRequestBodyStream implements HttpBody.Stream {
private boolean closing = false; private boolean closing = false;
private HttpBody.ChunkHandler handler; private HttpBody.ChunkHandler handler;
public Netty4HttpRequestBodyStream(Channel channel) { public Netty4HttpRequestBodyStream(Channel channel) {
this.channel = channel; this.channel = channel;
Netty4Utils.addListener(channel.closeFuture(), closeListener); Netty4Utils.addListener(channel.closeFuture(), closeListener);

2
server/src/main/java/org/elasticsearch/action/bulk/BulkOperation.java
View file

@ -438,7 +438,7 @@ final class BulkOperation extends ActionRunnable<BulkResponse> {
private void executeBulkShardRequest(BulkShardRequest bulkShardRequest, Releasable releaseOnFinish) { private void executeBulkShardRequest(BulkShardRequest bulkShardRequest, Releasable releaseOnFinish) {
ShardId shardId = bulkShardRequest.shardId(); ShardId shardId = bulkShardRequest.shardId();
// Short circuit the shark level request with the existing shard failure. // Short circuit the shard level request with the existing shard failure.
if (shortCircuitShardFailures.containsKey(shardId)) { if (shortCircuitShardFailures.containsKey(shardId)) {
handleShardFailure(bulkShardRequest, clusterService.state(), shortCircuitShardFailures.get(shardId)); handleShardFailure(bulkShardRequest, clusterService.state(), shortCircuitShardFailures.get(shardId));
releaseOnFinish.close(); releaseOnFinish.close();