better debug logging
Project: http://git-wip-us.apache.org/repos/asf/incubator-streams/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-streams/commit/9582c0cb Tree: http://git-wip-us.apache.org/repos/asf/incubator-streams/tree/9582c0cb Diff: http://git-wip-us.apache.org/repos/asf/incubator-streams/diff/9582c0cb Branch: refs/heads/STREAMS-46 Commit: 9582c0cb703f075b218016b0dac2e85708a71d14 Parents: c73dadd Author: sblackmon <[email protected]> Authored: Wed Jun 25 13:45:13 2014 -0500 Committer: sblackmon <[email protected]> Committed: Wed Jun 25 13:45:13 2014 -0500 ---------------------------------------------------------------------- .../org/apache/streams/elasticsearch/ElasticsearchQuery.java | 7 +++++-- 1 file changed, 5 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-streams/blob/9582c0cb/streams-contrib/streams-persist-elasticsearch/src/main/java/org/apache/streams/elasticsearch/ElasticsearchQuery.java ---------------------------------------------------------------------- diff --git a/streams-contrib/streams-persist-elasticsearch/src/main/java/org/apache/streams/elasticsearch/ElasticsearchQuery.java b/streams-contrib/streams-persist-elasticsearch/src/main/java/org/apache/streams/elasticsearch/ElasticsearchQuery.java index 393aa19..475d93c 100644 --- a/streams-contrib/streams-persist-elasticsearch/src/main/java/org/apache/streams/elasticsearch/ElasticsearchQuery.java +++ b/streams-contrib/streams-persist-elasticsearch/src/main/java/org/apache/streams/elasticsearch/ElasticsearchQuery.java @@ -138,17 +138,20 @@ public class ElasticsearchQuery implements Iterable<SearchHit>, Iterator<SearchH String searchJson; if( config.getSearch() != null ) { - LOGGER.info("Have config in Reader: %s", config.getSearch().toString()); + LOGGER.info("Have config in Reader: " + config.getSearch().toString()); try { searchJson = mapper.writeValueAsString(config.getSearch()); - LOGGER.info("Setting source: %s", searchJson); + LOGGER.info("Setting source: " + searchJson); search = search.setSource(searchJson); } catch (JsonProcessingException e) { LOGGER.warn("Could not apply _search supplied by config"); e.printStackTrace(); } + + LOGGER.info("Search Source is now " + search.toString()); + }
