Lint

Author: afoucret

x-pack/plugin/esql/src/main/java/org/elasticsearch/xpack/esql/inference/bulk/BulkInferenceExecutionState.java

@@ -59,18 +59,18 @@ public void onInferenceException(long seqNo, Exception e) {
     }
 
     public long fetchProcessedSeqNo(int retry) throws InterruptedException, TimeoutException {
-            while (retry > 0) {
-                if (finished()) {
-                    return -1;
-                }
-                retry--;
-                Long seqNo = processedSeqNoQueue.poll(1, TimeUnit.SECONDS);
-                if (seqNo != null) {
-                    return seqNo;
-                }
+        while (retry > 0) {
+            if (finished()) {
+                return -1;
             }
+            retry--;
+            Long seqNo = processedSeqNoQueue.poll(1, TimeUnit.SECONDS);
+            if (seqNo != null) {
+                return seqNo;
+            }
+        }
 
-            throw new TimeoutException("timeout waiting for inference response");
+        throw new TimeoutException("timeout waiting for inference response");
     }
 
     public InferenceAction.Response fetchBufferedResponse(long seqNo) {

x-pack/plugin/esql/src/main/java/org/elasticsearch/xpack/esql/inference/bulk/BulkInferenceExecutor.java

@@ -94,7 +94,8 @@ private void handleResponses(ActionListener<OutputType> listener, BulkInferenceE
             listener.onFailure(bulkExecutionState.getFailure());
         }
 
-        private void persistsInferenceResponses(BulkInferenceExecutionState bulkExecutionState) throws TimeoutException, InterruptedException {
+        private void persistsInferenceResponses(BulkInferenceExecutionState bulkExecutionState) throws TimeoutException,
+            InterruptedException {
             while (bulkExecutionState.finished() == false && bulkExecutionState.fetchProcessedSeqNo(INFERENCE_RESPONSE_TIMEOUT) >= 0) {
                 long persistedSeqNo = bulkExecutionState.getPersistedCheckpoint();