[
https://issues.apache.org/jira/browse/NIFI-4759?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16320296#comment-16320296
]
ASF GitHub Bot commented on NIFI-4759:
--------------------------------------
Github user mgaido91 commented on a diff in the pull request:
https://github.com/apache/nifi/pull/2392#discussion_r160685547
--- Diff:
nifi-nar-bundles/nifi-mongodb-bundle/nifi-mongodb-processors/src/main/java/org/apache/nifi/processors/mongodb/PutMongo.java
---
@@ -155,12 +155,7 @@ public void onTrigger(final ProcessContext context,
final ProcessSession session
try {
// Read the contents of the FlowFile into a byte array
final byte[] content = new byte[(int) flowFile.getSize()];
- session.read(flowFile, new InputStreamCallback() {
- @Override
- public void process(final InputStream in) throws
IOException {
- StreamUtils.fillBuffer(in, content, true);
- }
- });
+ session.read(flowFile, in -> StreamUtils.fillBuffer(in,
content, true));
--- End diff --
this is causing the error on Ci because of the unused import which
introduces. Since this is not related with the PR, can we get it back to its
original state?
> PutMongo fails when the update key is not _id
> ---------------------------------------------
>
> Key: NIFI-4759
> URL: https://issues.apache.org/jira/browse/NIFI-4759
> Project: Apache NiFi
> Issue Type: Bug
> Reporter: Mike Thomsen
> Assignee: Mike Thomsen
>
> This works:
> {
> "_id": "1234",
> "$set": { "msg": "Hello, world" }
> }
> This does not:
> {
> "uniqueKey": "12345",
> "$set": { "msg": "Hello, World" }
> }
--
This message was sent by Atlassian JIRA
(v6.4.14#64029)
