[
https://issues.apache.org/jira/browse/NIFI-5544?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16597296#comment-16597296
]
ASF GitHub Bot commented on NIFI-5544:
--------------------------------------
Github user MikeThomsen commented on a diff in the pull request:
https://github.com/apache/nifi/pull/2958#discussion_r213977393
--- Diff:
nifi-nar-bundles/nifi-mongodb-bundle/nifi-mongodb-processors/src/main/java/org/apache/nifi/processors/mongodb/GetMongo.java
---
@@ -204,144 +212,145 @@ private ObjectWriter getObjectWriter(ObjectMapper
mapper, String ppSetting) {
@Override
public void onTrigger(final ProcessContext context, final
ProcessSession session) throws ProcessException {
FlowFile input = null;
+ logger = getLogger();
+
if (context.hasIncomingConnection()) {
input = session.get();
-
if (input == null && context.hasNonLoopConnection()) {
return;
}
}
- final ComponentLog logger = getLogger();
+ final Document query = getQuery(context, session, input );
--- End diff --
I think I actually refactored this is another one of my Mongo commits... :-D
> Refactor GetMongo processor codebase
> ------------------------------------
>
> Key: NIFI-5544
> URL: https://issues.apache.org/jira/browse/NIFI-5544
> Project: Apache NiFi
> Issue Type: Improvement
> Reporter: Sivaprasanna Sethuraman
> Assignee: Sivaprasanna Sethuraman
> Priority: Minor
>
> Current codebase of the GetMongo processor can be improved.
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
