Github user danny0405 commented on a diff in the pull request:
https://github.com/apache/storm/pull/2803#discussion_r210478306
--- Diff:
external/storm-elasticsearch/src/main/java/org/apache/storm/elasticsearch/bolt/EsLookupBolt.java
---
@@ -76,12 +78,12 @@ public void process(Tuple tuple) {
}
private Collection<Values> lookupValuesInEs(Tuple tuple) throws
IOException {
- String index = tupleMapper.getIndex(tuple);
- String type = tupleMapper.getType(tuple);
- String id = tupleMapper.getId(tuple);
- Map<String, String> params = tupleMapper.getParams(tuple, new
HashMap<>());
+ String index = tupleMapper.getIndex(tuple);
+ String type = tupleMapper.getType(tuple);
+ String id = tupleMapper.getId(tuple);
+ Map<String, String> params = tupleMapper.getParams(tuple, new
HashMap<>());
--- End diff --
should indent with Tab
---
