Support Questions

Find answers, ask questions, and share your expertise

Flowfile is currently penalized in Apache NiFI between ExtractText and PutSQL processors in NiFi

avatar
Contributor
I have a requirement to read say name of users from a file(all in new lines) and insert to Database(oracle). I am using GetFile->SplitText->ExtractText->PutSql in NiFi. All works fine for less records(around 10 records). But when I try it for 50 or 100 plus records, the connection between ExtractText and PutSql, I am getting "A flowfile is currently penalized and data can not be processed at this time". Also all flowfiles remain in queue.

Note in PutSQL I am using simple sql (insert into users_table(user_name) values ('user123'); It works properly for 10, 20 records but when I provide 100+ records then it gets stuck.

1 ACCEPTED SOLUTION

avatar
Contributor

Hello I had asked this question. Now I think I have got a solution. In PutSql Processor, there is a property "Support Fragmented Transactions". If I set its value to be false, then it is proceeding and not penalising the flow files.(If we read more into it, it says something about fragment.identifier and count due to which it waits for all flow files.)

Note: It also mentions it is for respecting Atomicity.
Anyone can suggest if having this property as false is proper or not. As right now if I am updating it to false then it is not penalising.

View solution in original post

3 REPLIES 3

avatar
Community Manager

@AlokKumar, Welcome to our community! To help you get the best possible answer, I have tagged in our NiFi experts @MattWho @vaishaakb  who may be able to assist you further.

Please feel free to provide any additional information or details about your query, and we hope that you will find a satisfactory solution to your question.



Regards,

Vidya Sargur,
Community Manager


Was your question answered? Make sure to mark the answer as the accepted solution.
If you find a reply useful, say thanks by clicking on the thumbs up button.
Learn more about the Cloudera Community:

avatar
Contributor

Thanks @VidyaSargur 
Also I have replied which seems to be solution (property Support Framgmented Transactions as false in PutSql Processor) which seems to be helping.

avatar
Contributor

Hello I had asked this question. Now I think I have got a solution. In PutSql Processor, there is a property "Support Fragmented Transactions". If I set its value to be false, then it is proceeding and not penalising the flow files.(If we read more into it, it says something about fragment.identifier and count due to which it waits for all flow files.)

Note: It also mentions it is for respecting Atomicity.
Anyone can suggest if having this property as false is proper or not. As right now if I am updating it to false then it is not penalising.