streams-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From sblack...@apache.org
Subject incubator-streams git commit: found and fixed bug
Date Tue, 30 Jun 2015 19:22:44 GMT
Repository: incubator-streams
Updated Branches:
  refs/heads/STREAMS-333.2 [created] bbeb1c22d


found and fixed bug


Project: http://git-wip-us.apache.org/repos/asf/incubator-streams/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-streams/commit/bbeb1c22
Tree: http://git-wip-us.apache.org/repos/asf/incubator-streams/tree/bbeb1c22
Diff: http://git-wip-us.apache.org/repos/asf/incubator-streams/diff/bbeb1c22

Branch: refs/heads/STREAMS-333.2
Commit: bbeb1c22d67df4f5c86af316646ab723ed76d7b5
Parents: bcf3d31
Author: Steve Blackmon (@steveblackmon) <sblackmon@apache.org>
Authored: Tue Jun 30 14:22:39 2015 -0500
Committer: Steve Blackmon (@steveblackmon) <sblackmon@apache.org>
Committed: Tue Jun 30 14:22:39 2015 -0500

----------------------------------------------------------------------
 .../apache/streams/elasticsearch/ElasticsearchPersistUpdater.java  | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-streams/blob/bbeb1c22/streams-contrib/streams-persist-elasticsearch/src/main/java/org/apache/streams/elasticsearch/ElasticsearchPersistUpdater.java
----------------------------------------------------------------------
diff --git a/streams-contrib/streams-persist-elasticsearch/src/main/java/org/apache/streams/elasticsearch/ElasticsearchPersistUpdater.java
b/streams-contrib/streams-persist-elasticsearch/src/main/java/org/apache/streams/elasticsearch/ElasticsearchPersistUpdater.java
index d0a8ef3..8ab55ca 100644
--- a/streams-contrib/streams-persist-elasticsearch/src/main/java/org/apache/streams/elasticsearch/ElasticsearchPersistUpdater.java
+++ b/streams-contrib/streams-persist-elasticsearch/src/main/java/org/apache/streams/elasticsearch/ElasticsearchPersistUpdater.java
@@ -89,7 +89,7 @@ public class ElasticsearchPersistUpdater extends ElasticsearchPersistWriter
impl
         }
 
         if(!Strings.isNullOrEmpty(routing)) {
-            updateRequest = updateRequest.routing(parent);
+            updateRequest = updateRequest.routing(routing);
         }
 
         // add fields


Mime
View raw message