Skip to content

Commit 6215f2e

Browse files
authored
Get last primary term on every commit before calling IndexCommitListener (#94670)
Get the last primary term value before calling the IndexCommitListener. Relates ES-5258
1 parent cfbc796 commit 6215f2e

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

server/src/main/java/org/elasticsearch/index/engine/InternalEngine.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -347,11 +347,11 @@ private SoftDeletesPolicy newSoftDeletesPolicy() throws IOException {
347347
private CombinedDeletionPolicy.CommitsListener newCommitsListener() {
348348
final Engine.IndexCommitListener listener = engineConfig.getIndexCommitListener();
349349
if (listener != null) {
350-
var primaryTerm = config().getPrimaryTermSupplier().getAsLong();
351350
return new CombinedDeletionPolicy.CommitsListener() {
352351
@Override
353352
public void onNewAcquiredCommit(final IndexCommit commit, final Set<String> additionalFiles) {
354353
final IndexCommitRef indexCommitRef = acquireIndexCommitRef(() -> commit);
354+
var primaryTerm = config().getPrimaryTermSupplier().getAsLong();
355355
assert indexCommitRef.getIndexCommit() == commit;
356356
listener.onNewCommit(shardId, store, primaryTerm, indexCommitRef, additionalFiles);
357357
}

0 commit comments

Comments
 (0)