make sure ID is propagated to ES Writer
Project: http://git-wip-us.apache.org/repos/asf/incubator-streams/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-streams/commit/3d964977 Tree: http://git-wip-us.apache.org/repos/asf/incubator-streams/tree/3d964977 Diff: http://git-wip-us.apache.org/repos/asf/incubator-streams/diff/3d964977 Branch: refs/heads/springcleaning Commit: 3d9649774801f518cb5d393a5fa749697b299d6b Parents: f877c5f Author: sblackmon <[email protected]> Authored: Mon Apr 14 11:10:44 2014 -0500 Committer: sblackmon <[email protected]> Committed: Mon Apr 14 11:10:44 2014 -0500 ---------------------------------------------------------------------- .../streams/elasticsearch/ElasticsearchPersistReaderTask.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-streams/blob/3d964977/streams-contrib/streams-persist-elasticsearch/src/main/java/org/apache/streams/elasticsearch/ElasticsearchPersistReaderTask.java ---------------------------------------------------------------------- diff --git a/streams-contrib/streams-persist-elasticsearch/src/main/java/org/apache/streams/elasticsearch/ElasticsearchPersistReaderTask.java b/streams-contrib/streams-persist-elasticsearch/src/main/java/org/apache/streams/elasticsearch/ElasticsearchPersistReaderTask.java index 7750fac..2d9c951 100644 --- a/streams-contrib/streams-persist-elasticsearch/src/main/java/org/apache/streams/elasticsearch/ElasticsearchPersistReaderTask.java +++ b/streams-contrib/streams-persist-elasticsearch/src/main/java/org/apache/streams/elasticsearch/ElasticsearchPersistReaderTask.java @@ -38,7 +38,7 @@ public class ElasticsearchPersistReaderTask implements Runnable { e.printStackTrace(); break; } - item = new StreamsDatum(jsonObject); + item = new StreamsDatum(jsonObject, hit.getId()); item.getMetadata().put("id", hit.getId()); item.getMetadata().put("index", hit.getIndex()); item.getMetadata().put("type", hit.getType());
