Support Questions

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

Querydatabase Processor not updating update column vaule

Hi All,

Need help to sort-out on one scenario . I am using QueryDatabase processor for extracting delta record from the source and then i am using update attribute processor and finally ConvertAvroToOrc processor and output of these i am going to inject in our data lake that is hive. When the nifi trigger first time it extracted all the data and injected in dlake successfully but in day 2 when there were no record available in terms of new insert or delta it did not picked any record that is correct but its has not updated any value in the data Provenance section and my down stream is depend on it so if it will not update any thing then down stream will not get any flow file and down stream jobs are getting failed. So if any one can suggest me how to handle this type scenario where no records are available in the source for that day and we can generate one flow file to move further with zero count or something like that..Thanks you !!

3 REPLIES 3

Super Guru
@Shantanu kumar

Please refer to below link i have answered yesterday for similar kind of issue.

https://community.hortonworks.com/questions/176093/nifi-querydatabasetable-processor-returns-0-if-no...

@shu Can we do this by using UpdateAttribute processor with Advance options if possilbe please explain it.

Super Guru
@Shantanu kumar

Sorry to say, i am not able to understand how to do this case using UpdateAttribute processor. As i have tried my proposed approach using monitor activity processor.

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