From f8547ba7f6be83d92049437fca78bc1693f6a6ef Mon Sep 17 00:00:00 2001 From: David Turner Date: Fri, 3 Oct 2025 12:10:42 +0100 Subject: [PATCH] Reinstate comment lost in #135008 ... and reformat Javadoc --- .../org/elasticsearch/cluster/service/MasterService.java | 7 ++++--- 1 file changed, 4 insertions(+), 3 deletions(-) diff --git a/server/src/main/java/org/elasticsearch/cluster/service/MasterService.java b/server/src/main/java/org/elasticsearch/cluster/service/MasterService.java index 2620fcbad4475..f2121a08eadf7 100644 --- a/server/src/main/java/org/elasticsearch/cluster/service/MasterService.java +++ b/server/src/main/java/org/elasticsearch/cluster/service/MasterService.java @@ -1407,10 +1407,11 @@ private interface Batch { /** * Called when the batch is rejected due to the master service shutting down. * - * @param e is a {@link NotMasterException} to cause things like {@link TransportMasterNodeAction} to retry after - * submitting a task to a master which shut down. {@code e.getCause()} is the rejection exception, which should be a - * {@link EsRejectedExecutionException} with {@link EsRejectedExecutionException#isExecutorShutdown()} true. + * @param e is a {@link NotMasterException} to cause things like {@link TransportMasterNodeAction} to retry after submitting a task + * to a master which shut down. {@code e.getCause()} is the rejection exception, which should be a + * {@link EsRejectedExecutionException} with {@link EsRejectedExecutionException#isExecutorShutdown()} true. */ + // Should really be a NodeClosedException instead, but this exception type doesn't trigger retries today. void onRejection(NotMasterException e); /**