Thanks for your reply. please find the details what i am trying to achieve in the flow. First of all, i am loading the source data into table1 on daily scheduled basis. Then what am trying to do, whatever the data is loaded in Table 1.(using put data database record processor). i am doing few manipulation and loading into table 2 through store procedure. High level flow: Generate flow file--> Executegroovy(Get teh current time)-->executesqlrecord(using the store procedure-->executesqlrecord(fetch the latest records) Coming back to Generate flow file. there is no incoming connection to this. Just trying generate one flow file. Whatever its been loaded on the Table 1 on daily basis(~ 1m records) to have it single flow file. Then i am using one of groovy script to get the current date once this is done, we are calling store procedure with below condition CALL PROC1 (${CURR_TIME}) In this store procedure, we are tracking Start time of execution and end time of execution and keep maintain in audit tables. Then we are again executing below query to fetch the success records from table 2 and continue to further. Select * from Table 2 where CREATED_DTTM >= (select max(START_TIME) from AUDIT WHERE PROC_NAME like 'PROC1 ' AND RUN_STATUS = 'SUCCESS') Why we used max start time: Its happening on daily basis, so we are picking the records from max. Currently there is connectivity between table 1 load (put database record processor) and the table 2 loads. additionally wants to check, how can be add the dependency( Have to wait until the data has been loaded into table 1 then start the store procedure for table 2 loads) And more than welcome, if any alternative approach can be done for this requirement.
... View more
