removed an unneeded getInputStream command which threw a FileNotFound exception. Also - no exporting will occur if loading/verifying index template failed (but it will keep on retrying).

This commit is contained in:
Boaz Leskes 2013-12-30 22:36:40 +01:00
parent c0be4069da
commit 2f45c9638e

View file

@ -432,8 +432,8 @@ public class ESExporter extends AbstractLifecycleComponent<ESExporter> implement
return false;
}
boolean hasDoc = conn.getResponseCode() == 200;
conn.getInputStream().close(); // close and release to connection pool.
boolean hasDoc;
hasDoc = conn.getResponseCode() == 200;
// nothing there, lets create it
if (!hasDoc) {
@ -464,8 +464,8 @@ public class ESExporter extends AbstractLifecycleComponent<ESExporter> implement
try {
return checkAndUpload("_template/marvel", template);
} catch (IOException e) {
logger.error("error when checking/adding index template", e);
return false;
// if we're not sure of the template, we can't send data... re-raise exception.
throw new ElasticSearchException("failed to load/verify index template", e);
}
}