Support Questions

Find answers, ask questions, and share your expertise
Check out our newest addition to the community, the Cloudera Data Analytics (CDA) group hub.

NIFI ExecuteSQL processor is returning duplicate in random

New Contributor



Nifi 1.9.2, single node, single cluster.


I am using 5 ExecuteSql processor to bulk collect records from Oracle DB.

(each select query suppose to pick separate set of one fifth of total volume, logic is based on MOD function).

Predecessor for all the executesql processors is same (generateflowfile processor).


ExecuteSql processors are configured as ("TIMER Driven", concurrent task=40, run schedule=30 sec, "maximum rows per flowfile"=500 and "output batch size"=1).

We are starting the nifi flow, then generateflowfile processor is generating one flow file which is triggering executeSql processors.


But randomly in some of the runs, data is getting duplicated. 


Not sure if this is the issue with concurrent tasks or timer driven property.

Please help.


New Contributor

Please ignore. Problem was not in the configurations. 

View solution in original post


New Contributor

Please ignore. Problem was not in the configurations. 



What was the solution for this issue in not having duplicate records when using ExecuteSql in Nifi. how to avoid the duplicate records. My flow is ExecuteSql --> PutDatabaseREcords.




Take a Tour of the Community
Don't have an account?
Your experience may be limited. Sign in to explore more.