honeymoose
/
OpenSearch
mirror of https://github.com/honeymoose/OpenSearch.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Add more trace logging to gateway translog recovery

This commit is contained in:
Simon Willnauer 2014-12-10 11:05:38 +01:00
parent da11bf4c1d
commit 3b585e5a5e
1 changed files with 4 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
src/main/java/org/elasticsearch/index/gateway/local/LocalIndexShardGateway.java
View File

@ -250,12 +250,13 @@ public class LocalIndexShardGateway extends AbstractIndexShardComponent implemen
final Set<String> typesToUpdate = Sets.newHashSet(); final Set<String> typesToUpdate = Sets.newHashSet();
try { try {
logger.trace("recovering translog file: {} length: {}", recoveringTranslogFile, Files.size(recoveringTranslogFile));
TranslogStream stream = TranslogStreams.translogStreamFor(recoveringTranslogFile); TranslogStream stream = TranslogStreams.translogStreamFor(recoveringTranslogFile);
try { try {
in = stream.openInput(recoveringTranslogFile); in = stream.openInput(recoveringTranslogFile);
} catch (TruncatedTranslogException e) { } catch (TruncatedTranslogException e) {
// file is empty or header has been half-written and should be ignored // file is empty or header has been half-written and should be ignored
logger.trace("ignoring truncation exception, the translog is either empty or half-written ([{}])", e.getMessage()); logger.trace("ignoring truncation exception, the translog is either empty or half-written", e);
} }
while (true) { while (true) {
if (in == null) { if (in == null) {
@ -269,11 +270,11 @@ public class LocalIndexShardGateway extends AbstractIndexShardComponent implemen
operation = stream.read(in); operation = stream.read(in);
} catch (EOFException e) { } catch (EOFException e) {
// ignore, not properly written the last op // ignore, not properly written the last op
logger.trace("ignoring translog EOF exception, the last operation was not properly written ([{}])", e.getMessage()); logger.trace("ignoring translog EOF exception, the last operation was not properly written", e);
break; break;
} catch (IOException e) { } catch (IOException e) {
// ignore, not properly written last op // ignore, not properly written last op
logger.trace("ignoring translog IO exception, the last operation was not properly written ([{}])", e.getMessage()); logger.trace("ignoring translog IO exception, the last operation was not properly written", e);
break; break;
} }
try { try {