[NIFI-7195] PutMongoRecord processor incorrectly routes failure flow files

• Type: Bug
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 1.9.2
• Fix Version/s: 1.12.0, 1.11.4
• Assignee: Pierre Villard
• Reporter: Andrey
• Created: 25/Feb/20 08:29
• Updated: 09/Mar/20 18:46
• Resolved: 08/Mar/20 15:02

Description

Hello!

When I use batch processor for inserting data to Mongo, if I get some error like "write errors: [BulkWriteError

{index=0, code=11000, message='E11000 duplicate key error collection" flow file is not routed to the failure relationship, but processor tries to repeat data process. I think it depends on this part of source code:

catch (SchemaNotFoundException | IOException | MalformedRecordException e) 

Apparently the exception is not caught:

https://github.com/apache/nifi/blob/master/nifi-nar-bundles/nifi-mongodb-bundle/nifi-mongodb-processors/src/main/java/org/apache/nifi/processors/mongodb/PutMongoRecord.java#L147

 I think it is not normal processor behavior.

Issue Links

• links to: GitHub Pull Request #4089