@J0sh ,   If you use a ReplaceText with the following settings it will clean up the garbage in your flowfiles: Search Value: (?s)(^|(\})<br>).*?(\n).*?(<br>(\{)|$) Replacement Value: $2$3$5   This file, though, has not 1 JSON, but 8 different JSON fragments. So the resulting flowfile will still have 8 lines, each with a valid JSON. You must use a SplitText process to separate those into 8 different flowfiles before applying the EvaluateJSONPath.   Cheers, André   ... View more

@r_rachuri ,   Your expression works for me on NiFi 1.15.2. It's too complicated, though, and it still leaves a pair of curly brackets behind.   Try using this one instead: \{[ \n]*\}[ \n]*,?[ \n]*   Cheers, André     ... View more

@Seaport ,   Please try the below: import json def jsonize(k, v): ret = json.loads(v) ret.update({'key': k}) return ret ... rdd = reader.map(lambda x: jsonize(*x)) ...   You need to make sure your schema includes the added key column.   Cheers, André   ... View more

@Rohan44 ,   Unfortunately, I don't think there's a way to do that. What are you using to write the files to HDFS?   Cheers, André   ... View more

@Rohan44 ,   Try creating your datafile with each JSON record in a single line, like so: {"buyer":{"legalBusinessName":"test1 Company","organisationIdentifications":[{"type":"abcd","identification":"test.bb@tesr"},{"type":"TXID","identification":"12345678"}]},"supplier":{"legalBusinessName":"test Company","organisationIdentifications":[{"type":"abcd","identification":"test28@test"}]},"paymentRecommendationId":"1234-5678-9876-2212-123456","excludedRemittanceInformation":[],"recommendedPaymentInstructions":[{"executionDate":"2022-06-12","paymentMethod":"aaaa","remittanceInformation":{"structured":[{"referredDocumentInformation":[{"type":"xxx","number":"12341234","relatedDate":"2022-06-12","paymentDueDate":"2022-06-12","referredDocumentAmount":{"remittedAmount":2600.5,"duePayableAmount":3000}}]}]}}]}   Cheers, André   ... View more