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

added routing_format=full to default toXContent params 

Original commit: elastic/x-pack-elasticsearch@362429d9b7
This commit is contained in:
Boaz Leskes 2013-09-30 20:13:58 +02:00
parent 41c7e045a7
commit f4e41585d9
1 changed files with 7 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
src/main/java/org/elasticsearch/enterprise/monitor/exporter/ESExporter.java
View File

@ -61,7 +61,7 @@ public class ESExporter extends AbstractLifecycleComponent<ESExporter> implement
timeout = (int) settings.getAsTime("timeout", new TimeValue(6000)).seconds();
xContentParams = new ToXContent.MapParams(
ImmutableMap.of("load_average_format", "hash"));
ImmutableMap.of("load_average_format", "hash", "routing_format", "full"));
logger.info("ESExporter initialized. Targets: {}, index prefix [{}], index time format [{}]", hosts, indexPrefix, indexTimeFormat);
@ -97,15 +97,15 @@ public class ESExporter extends AbstractLifecycleComponent<ESExporter> implement
;
}
logger.debug("Exporting {}", type);
logger.debug("exporting {}", type);
HttpURLConnection conn = openConnection("POST", "/_bulk", XContentType.SMILE.restContentType());
if (conn == null) {
logger.error("Could not connect to any configured elasticsearch instances: [{}]", hosts);
logger.error("could not connect to any configured elasticsearch instances: [{}]", hosts);
return;
}
try {
OutputStream os = conn.getOutputStream();
// TODO: find a way to disable builder's substream flushing.
// TODO: find a way to disable builder's substream flushing or something neat solution
for (ToXContent xContent : xContentArray) {
XContentBuilder builder = XContentFactory.smileBuilder(os);
builder.startObject().startObject("index")
@ -133,7 +133,7 @@ public class ESExporter extends AbstractLifecycleComponent<ESExporter> implement
} catch (IOException e) {
logger.error("Error connecting to target", e);
logger.error("error sending data", e);
return;
}
@ -181,7 +181,7 @@ public class ESExporter extends AbstractLifecycleComponent<ESExporter> implement
return conn;
} catch (IOException e) {
logger.error("error connecting to [{}]: {}", host, e);
logger.error("error connecting to [{}]", e, host);
}
}
@ -230,7 +230,7 @@ public class ESExporter extends AbstractLifecycleComponent<ESExporter> implement
}
checkedForIndexTemplate = true;
} catch (IOException e) {
logger.error("Error when checking/adding metrics template to elasticsearch", e);
logger.error("error when checking/adding template to elasticsearch", e);
return false;
}
return true;