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
|