You can use " ConvertAvroToJSON" and then  the "EvaluateJsonPath" Processor and add there the Property like "workingHours" and as Value you set your JsonKey like $.hours With this you add it to the attribute of your FlowFile. ... View more

You can use " QueryDatabaseTable" as input processor, but you can´t use it twice in one flow (Im searching for a solution that I can get a delta in one flow for 2 Fields btw. :D). You have to set the Property "Maximum-value Columns". It can be a date, id or something else to have the maximum of a value. At "view state" you can see the value of "Maximum-value Columns" field you set. To set up the runtime you can go to "Schedule" at the processor and change the "Run Schedule"   If you need more input, please let me know ... View more

You don´t need a particular exception. In catch block of onTrigger method you add like session.transfer(flowFile , REL_ FAILURE ) ;   ... View more

You specify the string "JSON_PATH" as the path, which cannot be resolved and thus leads to a nullpointer.   Should be like: String jsonPath = context.getProperty(JSON_PATH).getValue();  Object obj = new JSONParser().parse(new FileReader(jsonPath));   ... View more