streams-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From sblack...@apache.org
Subject git commit: better debug logging
Date Wed, 25 Jun 2014 18:45:22 GMT
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 <sblackmon@w2odigital.com>
Authored: Wed Jun 25 13:45:13 2014 -0500
Committer: sblackmon <sblackmon@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());
+
             }
 
 


Mime
View raw message