From a765a47af6cee4e08be32c0dc81281929469d407 Mon Sep 17 00:00:00 2001
From: danielhuang <danielhuang@tencent.com>
Date: Tue, 29 Oct 2019 21:58:56 +0800
Subject: [PATCH] change request to in flight request breaker

---
 .../main/java/org/elasticsearch/transport/InboundHandler.java   | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/server/src/main/java/org/elasticsearch/transport/InboundHandler.java b/server/src/main/java/org/elasticsearch/transport/InboundHandler.java
index 36860a45edb50..9e2e6302ae832 100644
--- a/server/src/main/java/org/elasticsearch/transport/InboundHandler.java
+++ b/server/src/main/java/org/elasticsearch/transport/InboundHandler.java
@@ -201,7 +201,7 @@ private <T extends TransportResponse> void handleResponse(InetSocketAddress remo
                                                               final TransportResponseHandler<T> handler, int messageLengthBytes) {
         final T response;
         long bytesNeedToRelease = 0;
-        CircuitBreaker breaker = circuitBreakerService.getBreaker(CircuitBreaker.REQUEST);
+        CircuitBreaker breaker = circuitBreakerService.getBreaker(CircuitBreaker.IN_FLIGHT_REQUESTS);
         try {
             if (handler.canTripCircuitBreaker() && messageLengthBytes > 1024) {
                 // the main purpose is to check memory before deserialization for large size of response