[
https://issues.apache.org/jira/browse/NIFI-10893?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Pierre Villard resolved NIFI-10893.
-----------------------------------
Resolution: Feedback Received
Apache NiFi 1.x is no longer maintained and no new release is planned on the
1.x release line. Marking as resolved as part of a cleanup operation. Please
open a new one with an updated description if this is still relevant for NiFi
2.x.
> PutMongo doesn't seem to support arrayFilters
> ---------------------------------------------
>
> Key: NIFI-10893
> URL: https://issues.apache.org/jira/browse/NIFI-10893
> Project: Apache NiFi
> Issue Type: Bug
> Components: Extensions
> Affects Versions: 1.16.3
> Environment: Official Docker
> Reporter: Benji Benning
> Priority: Major
> Labels: MongoDB
>
> Using PutMongo set to Update with Operators enabled, fails when using
> arrayFilters.
> FYI arrayFilters are used to update nested arrays.
> The Update query is a simple match on a key. ( \{ "matchingkey": "xxxx" } )
> The document i'm using for the update is something like this:
> {noformat}
> {
> "$set": {
> "first.$[levela].second.$[levelb].thiskey": "update_this"
> }
> },
> {
> "arrayFilters": [
> {
> "levela.mainID": "12345"
> },
> {
> "levelb.subID": "abcde"
> } ]
> }{noformat}
> The error i'm getting is:
> {noformat}
> 2022-11-27 20:31:17,359 ERROR [Timer-Driven Process Thread-226]
> o.a.nifi.processors.mongodb.PutMongo
> [PutMongo[id=017b1128-0280-1fa9-8cae-35df4120012f],
> StandardFlowFileRecord[uuid=97ecb515-6619-4fb2-a39a-625aceedb755,claim=StandardContentClaim
> [resourceClaim=StandardResourceClaim[id=1669580444646-191,
> container=default, section=191], offset=749291,
> length=361],offset=0,name=4486523b-5c3d-49a4-b4a6-a209279ed351,size=361],
> com.mongodb.MongoWriteException: Write operation error on server
> mongodbdev1:27017. Write error: WriteError{code=2, message='No array filter
> found for identifier 'levela' in path
> 'first.$[levela].second.$[levelb].thiskey'', details={}}.] Failed to insert
> {} into MongoDB due to {}
> com.mongodb.MongoWriteException: Write operation error on server
> mongodbdev1:27017. Write error: WriteError{code=2, message='No array filter
> found for identifier 'levela' in path
> 'first.$[levela].second.$[levelb].thiskey'', details={}}.
> at
> com.mongodb.client.internal.MongoCollectionImpl.executeSingleWriteRequest(MongoCollectionImpl.java:1018)
> at
> com.mongodb.client.internal.MongoCollectionImpl.executeUpdate(MongoCollectionImpl.java:994)
> at
> com.mongodb.client.internal.MongoCollectionImpl.updateOne(MongoCollectionImpl.java:579)
> at
> org.apache.nifi.processors.mongodb.PutMongo.onTrigger(PutMongo.java:233)
> at
> org.apache.nifi.processor.AbstractProcessor.onTrigger(AbstractProcessor.java:27)
> at
> org.apache.nifi.controller.StandardProcessorNode.onTrigger(StandardProcessorNode.java:1283)
> at
> org.apache.nifi.controller.tasks.ConnectableTask.invoke(ConnectableTask.java:214)
> at
> org.apache.nifi.controller.scheduling.AbstractTimeBasedSchedulingAgent.lambda$doScheduleOnce$0(AbstractTimeBasedSchedulingAgent.java:63)
> at org.apache.nifi.engine.FlowEngine$2.run(FlowEngine.java:110)
> at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
> at java.util.concurrent.FutureTask.run(FutureTask.java:266)
> at
> java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$201(ScheduledThreadPoolExecutor.java:180)
> at
> java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:293)
> at
> java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
> at
> java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
> at java.lang.Thread.run(Thread.java:750){noformat}
> I've also tried to simplify the Update with moving to 1 object in
> arrayFilters, same issue. Looks like PutMongo entirely ignores the second
> part of the update document.
> Performing this update using other tools or python (my workaround) works fine.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
