You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@streams.apache.org by sb...@apache.org on 2014/06/25 20:45:22 UTC
git commit: better debug logging
Repository: incubator-streams
Updated Branches:
refs/heads/STREAMS-111 c73dadd74 -> 9582c0cb7
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-111
Commit: 9582c0cb703f075b218016b0dac2e85708a71d14
Parents: c73dadd
Author: sblackmon <sb...@w2odigital.com>
Authored: Wed Jun 25 13:45:13 2014 -0500
Committer: sblackmon <sb...@w2odigital.com>
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());
+
}