From 5f3d2d897f5ba595aebacfe9724acfbd1ca65859 Mon Sep 17 00:00:00 2001 From: Jason Tedor Date: Thu, 13 Apr 2017 08:09:53 -0400 Subject: [PATCH] Return local variables --- .../org/elasticsearch/index/engine/InternalEngine.java | 9 ++++++--- 1 file changed, 6 insertions(+), 3 deletions(-) diff --git a/core/src/main/java/org/elasticsearch/index/engine/InternalEngine.java b/core/src/main/java/org/elasticsearch/index/engine/InternalEngine.java index 5f98ad9658692..fe01842053c1a 100644 --- a/core/src/main/java/org/elasticsearch/index/engine/InternalEngine.java +++ b/core/src/main/java/org/elasticsearch/index/engine/InternalEngine.java @@ -1694,6 +1694,9 @@ private long commitIndexWriter(final IndexWriter writer, final Translog translog try { final long localCheckpoint = seqNoService().getLocalCheckpoint(); final Translog.TranslogGeneration translogGeneration = translog.getMinGenerationForSeqNo(localCheckpoint + 1); + final String translogFileGeneration = Long.toString(translogGeneration.translogFileGeneration); + final String translogUUID = translogGeneration.translogUUID; + final String localCheckpointValue = Long.toString(localCheckpoint); writer.setLiveCommitData(() -> { /* @@ -1706,9 +1709,9 @@ private long commitIndexWriter(final IndexWriter writer, final Translog translog * of invocation of the commit data iterator (which occurs after all documents have been flushed to Lucene). */ final Map commitData = new HashMap<>(5); - commitData.put(Translog.TRANSLOG_GENERATION_KEY, Long.toString(translogGeneration.translogFileGeneration)); - commitData.put(Translog.TRANSLOG_UUID_KEY, translogGeneration.translogUUID); - commitData.put(SequenceNumbers.LOCAL_CHECKPOINT_KEY, Long.toString(localCheckpoint)); + commitData.put(Translog.TRANSLOG_GENERATION_KEY, translogFileGeneration)); + commitData.put(Translog.TRANSLOG_UUID_KEY, translogUUID); + commitData.put(SequenceNumbers.LOCAL_CHECKPOINT_KEY, localCheckpointValue); if (syncId != null) { commitData.put(Engine.SYNC_COMMIT_ID, syncId); }