Hi Joel, thanks for the reply. Since I am new to nifi, kindly let me know what do you mean by creating function. All I am doing is fetching the time from the mysql table and inserting it into the Out port. Next, In the another procsss group, fetching the time and extracting the date, time, etc from IN port and then trying to use it in the form of ${hour} ${minute} as cron. But use of '$' and '{' makes it an invalid cron . Another solution which I came with was using RouteOnAttribute which will compare the current timestamp now() with the timedate fetched and on matching , it will proceed further. This solution works but it is not an efficient one as the RouteOnattribute needs to continuously run and check the timestamp . Please let me know some other solution.
... View more
