Member since
06-26-2015
509
Posts
136
Kudos Received
114
Solutions
My Accepted Solutions
Title | Views | Posted |
---|---|---|
1332 | 09-20-2022 03:33 PM | |
3867 | 09-19-2022 04:47 PM | |
2274 | 09-11-2022 05:01 PM | |
2370 | 09-06-2022 02:23 PM | |
3725 | 09-06-2022 04:30 AM |
09-19-2022
10:03 PM
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
09-15-2022
06:54 AM
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
09-12-2022
07:40 AM
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
09-09-2022
04:43 PM
@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
09-07-2022
05:04 AM
1 Kudo
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
09-07-2022
12:34 AM
@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
09-06-2022
03:24 PM
@rafy , Same approach. Just create the processor(s) and let the files flow through it 🙂 Cheers, André
... View more
09-06-2022
10:57 AM
Thanks for the info, that's very useful. It's Hive 3.1.2, Cloudera ODBC for Hive 2.6.1 Interestingly I get the following results querying though the ODBC driver (use native query = false) SELECT extract (year FROM "datecolumn") -- accepted SELECT { fn extract (year FROM "datecolumn") } -- ParseException and yet SELECT { fn year("datecolumn") } - accepted So there may be an inconsistency in the way the driver parses the ODBC function syntax. Mark
... View more
09-05-2022
03:54 PM
@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
09-05-2022
03:48 PM
@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