Github user MikeThomsen commented on a diff in the pull request:
https://github.com/apache/nifi/pull/2443#discussion_r170616361
--- Diff:
nifi-nar-bundles/nifi-mongodb-bundle/nifi-mongodb-processors/src/main/java/org/apache/nifi/processors/mongodb/GetMongo.java
---
@@ -236,12 +261,33 @@ public void onTrigger(final ProcessContext context,
final ProcessSession session
context.getProperty(QUERY).evaluateAttributeExpressions().getValue());
}
- final Document query = context.getProperty(QUERY).isSet()
- ?
Document.parse(context.getProperty(QUERY).evaluateAttributeExpressions().getValue())
: null;
+ final Document query;
+ if (context.getProperty(QUERY).isSet()) {
+ String queryStr =
context.getProperty(QUERY).evaluateAttributeExpressions(input).getValue();
+ query = Document.parse(queryStr);
+ } else if (!context.getProperty(QUERY).isSet() && input == null) {
+ query = Document.parse("{}");
--- End diff --
Ok. I think what I'll do is just put the query attribute on there no matter
what if the query attribute is set because that'll help people figure out what
happened in every scenario where a query was sent to Mongo.
---
