Hi Till
I have 2 kind of data
a) read the data from database put into the memory and nosql database so have 1 source & custom sink operator
Job1 ------>Source--->NoSQL Sink-->status
b) once the data is updated into the memory i need to run the second job so i am checking the status return by the first job so have another source where some historical data is coming so have 1 source & 1 flatmap
and output sink
Job2 ------>Source2-->Check in cache built from first job --> if exist execute rules ---> dump to file
so if(Job1==true)
{
execute Job2
}