Repository: incubator-streams Updated Branches: refs/heads/master 0c4087ca6 -> 3856581a8
STREAMS-437: Resolved Project: http://git-wip-us.apache.org/repos/asf/incubator-streams/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-streams/commit/3856581a Tree: http://git-wip-us.apache.org/repos/asf/incubator-streams/tree/3856581a Diff: http://git-wip-us.apache.org/repos/asf/incubator-streams/diff/3856581a Branch: refs/heads/master Commit: 3856581a8bfd2b601d50765afd21c289537a1119 Parents: 0c4087c Author: Steve Blackmon @steveblackmon <[email protected]> Authored: Sun Oct 23 19:50:35 2016 -0500 Committer: Steve Blackmon @steveblackmon <[email protected]> Committed: Sun Oct 23 19:50:35 2016 -0500 ---------------------------------------------------------------------- .../elasticsearch/processor/DatumFromMetadataProcessor.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-streams/blob/3856581a/streams-contrib/streams-persist-elasticsearch/src/main/java/org/apache/streams/elasticsearch/processor/DatumFromMetadataProcessor.java ---------------------------------------------------------------------- diff --git a/streams-contrib/streams-persist-elasticsearch/src/main/java/org/apache/streams/elasticsearch/processor/DatumFromMetadataProcessor.java b/streams-contrib/streams-persist-elasticsearch/src/main/java/org/apache/streams/elasticsearch/processor/DatumFromMetadataProcessor.java index f1b7bfc..7897e8d 100644 --- a/streams-contrib/streams-persist-elasticsearch/src/main/java/org/apache/streams/elasticsearch/processor/DatumFromMetadataProcessor.java +++ b/streams-contrib/streams-persist-elasticsearch/src/main/java/org/apache/streams/elasticsearch/processor/DatumFromMetadataProcessor.java @@ -82,7 +82,7 @@ public class DatumFromMetadataProcessor implements StreamsProcessor, Serializabl getRequestBuilder.setFetchSource(true); GetResponse getResponse = getRequestBuilder.get(); - if( getResponse == null || getResponse.isExists() || getResponse.isSourceEmpty() ) + if( getResponse == null || !getResponse.isExists() || getResponse.isSourceEmpty() ) return result; entry.setDocument(getResponse.getSource());
