Thanks @SAMSAL  and @araujo for the responses.  The RouteOnAttribute is what I am using presently but it gets unwieldily after just a couple of route options.  Looks like I'm just gonna need to build a custom validator using the ExecuteScript processor.  Hopefully that scales.  ... View more

hi @araujo    the userPrincipalName of user livy is:   livy/hostname_livy_server@DOMAIN.LOCAL     the userPrincipalName of the livy-http user is:   livy-http@DOMAIN.LOCAL     running the command "kinit livy":     running the command "kinit livy-http":     running the "kinit" command with the keytab created for user livy:     running the command "kinit" with the keytab created for the user livy-http:     we've been facing this problem for months, we haven't found the solution yet. ... View more

Hi @araujo,   My apologies for coming back late.   The job reads from 2 Kafka sources and send the data to Kinesis stream (sink).   Thanks, Prabu. ... View more

@VenkatG Has the reply helped resolve your issue? If so, please mark the appropriate reply as the solution, as it will make it easier for others to find the answer in the future. Thanks ... View more

Everything you do in the NiFi UI can also be done using the NiFi REST API. So if you want/need to automate it, it's totally possible and not difficult.   Cheers, André ... View more

@JimHalfpenny and @araujo thanks both of you for your help! The solution of creating a view with some kind of placeholders worked for me! ... View more

@rafy ,   Same approach. Just create the processor(s) and let the files flow through it 🙂   Cheers, André   ... View more

@Ahmed_Abuhaimed ,   Have you looked into change data capture functionality for Hana? https://help.sap.com/docs/SAP_DATA_INTELLIGENCE/1c1341f6911f4da5a35b191b40b426c8/023c75aedfdd4646934f2d9ccde5660a.html   Cheers, André   ... View more

@samrathal ,   Is seems that "subtract" only works for integers and your value is a long. The longSubtract function only works if longs are passed as parameters and I don't know if there's a way to specify a long literal in Jolt (I tried 60L but that doesn't work).   The following does a little bit more work but also achieves what you want:   [ { "operation": "modify-overwrite-beta", "spec": { "currenttime": "=toLong(${now():toNumber()})", "minute": "=toLong(60)" } }, { "operation": "modify-overwrite-beta", "spec": { "timeOneMinu": "=longSubtract(@(1,currenttime), @(1,minute))" } }, { "operation": "remove", "spec": { "minute": "" } } ]     Output: { "currenttime": 1662417935173, "timeOneMinu": 1662417935113 } Cheers, André ... View more