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

Gateway: added trace logging to translog recovery logic 

Enabled it in SimpleRecoveryLocalGatewayTests
This commit is contained in:
Boaz Leskes 2014-09-10 16:00:59 +02:00
parent 7fdd3651fa
commit 7d80db7c2c
2 changed files with 4 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -238,6 +238,7 @@ public class LocalIndexShardGateway extends AbstractIndexShardComponent implemen
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());
} }
while (true) { while (true) {
if (in == null) { if (in == null) {
@ -251,9 +252,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());
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());
break; break;
} }
try { try {

2
src/test/java/org/elasticsearch/gateway/local/SimpleRecoveryLocalGatewayTests.java
View File

@ -54,7 +54,7 @@ import static org.hamcrest.Matchers.*;
*/ */
@ClusterScope(numDataNodes = 0, scope = Scope.TEST) @ClusterScope(numDataNodes = 0, scope = Scope.TEST)
@Slow @Slow
@TestLogging("index.shard.service:TRACE") @TestLogging("index.shard.service:TRACE,index.gateway.local:TRACE")
public class SimpleRecoveryLocalGatewayTests extends ElasticsearchIntegrationTest { public class SimpleRecoveryLocalGatewayTests extends ElasticsearchIntegrationTest {
private ImmutableSettings.Builder settingsBuilder() { private ImmutableSettings.Builder settingsBuilder() {