You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@streams.apache.org by sb...@apache.org on 2016/10/24 00:56:10 UTC
incubator-streams git commit: STREAMS-437: Resolved
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 <sb...@apache.org>
Authored: Sun Oct 23 19:50:35 2016 -0500
Committer: Steve Blackmon @steveblackmon <sb...@apache.org>
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());