Comment about interrupt

albertzaharovits · albertzaharovits · commit 0959714810e8 · 2025-03-06T15:12:08.000+02:00
diff --git a/server/src/main/java/org/elasticsearch/index/engine/ThreadPoolMergeScheduler.java b/server/src/main/java/org/elasticsearch/index/engine/ThreadPoolMergeScheduler.java
@@ -400,7 +400,8 @@ public void run() {
         }
 
         void abortOnGoingMerge() {
-            // This interrupts the IndexWriter.
+            // {@code IndexWriter} checks the abort flag internally, while running the merge.
+            // The segments of an aborted merge become available to subsequent merges.
             onGoingMerge.getMerge().setAborted();
             // This ensures {@code OneMerge#close} gets invoked.
             // {@code IndexWriter} considers a merge as "running" once it has been pulled from the {@code MergeSource#getNextMerge},

Original file line number	Diff line number	Diff line change
`@@ -400,7 +400,8 @@ public void run() {`
`400`	`400`	`}`
`401`	`401`
`402`	`402`	`void abortOnGoingMerge() {`
`403`		`- // This interrupts the IndexWriter.`
	`403`	`+ // {@code IndexWriter} checks the abort flag internally, while running the merge.`
	`404`	`+ // The segments of an aborted merge become available to subsequent merges.`
`404`	`405`	`onGoingMerge.getMerge().setAborted();`
`405`	`406`	`// This ensures {@code OneMerge#close} gets invoked.`
`406`	`407`	`// {@code IndexWriter} considers a merge as "running" once it has been pulled from the {@code MergeSource#getNextMerge},`