Member since
06-26-2015
509
Posts
136
Kudos Received
114
Solutions
My Accepted Solutions
Title | Views | Posted |
---|---|---|
1316 | 09-20-2022 03:33 PM | |
3856 | 09-19-2022 04:47 PM | |
2270 | 09-11-2022 05:01 PM | |
2357 | 09-06-2022 02:23 PM | |
3704 | 09-06-2022 04:30 AM |
08-30-2022
03:41 PM
@yagoaparecidoti , The opposite command doesn't exist, as far as I know. Querying the database is the only option that I'm aware. Cheers, André
... View more
08-30-2022
06:36 AM
Could you please run the kinit commands for both accounts and share a screenshot showing the command line and the output?
... View more
08-30-2022
06:32 AM
The names you listed are the servicePrincipalName. These are different from the userPrincipalName. Could you please check the latter and let me know what they are? Cheers, André
... View more
08-30-2022
05:24 AM
@sathish3389 , One way to do this is to use the ExecuteScript processor with a script like the one below. This script with set the attribute dv_sys_id with the content that you want and will also add that to the content of the flowfile. from org.apache.commons.io import IOUtils
from java.nio.charset import StandardCharsets
from org.apache.nifi.processor.io import StreamCallback
import json
class PyStreamCallback(StreamCallback):
def __init__(self):
self.dv_sys_id = None
def process(self, inputStream, outputStream):
text = IOUtils.toString(inputStream, StandardCharsets.UTF_8)
obj = json.loads(text)
self.dv_sys_id = 'dv_sys_id=%s' % (','.join(obj['dv_sys_id'],))
outputStream.write(bytearray(self.dv_sys_id.encode('utf-8','ignore')))
flow_file = session.get()
if flow_file != None:
callback = PyStreamCallback()
flow_file = session.write(flow_file, callback)
flow_file = session.putAttribute(flow_file, 'dv_sys_id', callback.dv_sys_id)
session.transfer(flow_file, REL_SUCCESS) Cheers, André
... View more
08-30-2022
04:31 AM
@lie , MySQL 8 is not a supported version for CM/CDH 6.3.1, which is the version you're using, as you can see here: https://docs.cloudera.com/documentation/enterprise/6/release-notes/topics/rg_database_requirements.html You should pick a version that is compatible with your CDH version. Alternatively, you can upgrade to CDP. Cheers, André
... View more
08-29-2022
04:49 PM
@Uday483 , Unfortunately the template option only works for a single domain with LDAP, I'm afraid. One thing you can test is to set "ldap.auth.user.dn.template = {0}". With this, though, when the client authenticate they would have to specify the qualified user name rather then just the short name (e.g. alice@domain1.org.com, or bob@domain2.org.com). I haven't tested this before, so I'm not 100% sure it will work. Can you use Kerberos authentication instead of LDAP? With Kerberos auth there should be no problems. Cheers, André
... View more
08-29-2022
04:43 PM
@Curry5103 , ListenSyslog can receive a very large amount of data and it may be hard to match the throughput of that with an InvokeHTTP processor. To avoid dropping syslog messages, especially if using UDP protocol, you will probably need to provide enough buffer for those messages to decouple the receipt of the messages from the InvokeHTTP execution. You can do that in NiFi by increase the maximum queue size limits, or maybe use something like Kafka, where you can temporarily store the syslog messages and another flow can read from Kafka and call InvokeHTTP for each of them. Cheers, André
... View more
08-29-2022
04:34 PM
Not sure what's going on. What's your job doing?
... View more
08-29-2022
04:04 PM
@yagoaparecidoti , You can do the reverse with the command "SHOW ROLE GRANT GROUP group name;". I don't think there's a command to do exactly what you need, but you can query the database directly: select
r.ROLE_NAME,
g.GROUP_NAME
from
SENTRY_GROUP g
join SENTRY_ROLE_GROUP_MAP rg on rg.GROUP_ID = g.GROUP_ID
join SENTRY_ROLE r on r.ROLE_ID = rg.ROLE_ID
order by
r.ROLE_NAME,
g.GROUP_NAME
; Cheers, André
... View more
08-29-2022
03:54 PM
@yagoaparecidoti , Do you know the passwords for the users livy and livy-http? Can you manually kinit with those 2 users from the command line? Can you also check in AD what's the value for userPrincipalName property of those two users and share it here? Cheers, André
... View more