Hello Sir,   It worked... thank you so much!!! ... View more

Thanks for the response @jsensharma    I do not want point to a python script file and invoke the interpreter.   I have scenario where python code is present in flowfile attribute or a variable and want to run it in ExecuteStreamCommand processor. I can not use ExecuteScript processor because it invokes Jython based interpreter. Am using ExecuteStreamCommand processor as I want to explicitly invoke Python 3.5 interpreter.   If there is no workaround, What is standard way for having script location. Placing the script file in NiFi server might be risk because other users might accidentally modify/delete it. How to avoid it? ... View more

@Quang_Vu_Blog  As per kafka-connect docs the default port "rest.port" is 8083  rest.port - the port the REST interface listens on for HTTP requests   So are you getting conflict on port 8003 (or there is a typo ? is it 8083)  Can you try changing the "rest.port" in your worker config to something else and then try again. Also please try to run the below commands before starting kafka-connect to verify if there is any port conflict? Or if there are any bind address issue   # netstat -tnlpa | grep 8083 # netstat -tnlpa | grep 8003   . ... View more

@johnwook Sorry, You can not change password for local user from CDSW directly. Though forgot password method is a workaround for this. Please enter this URL in browser http://cdsw.company.com/forgot-password and then follow the Wizard, you will be able to put new password here.   Cheers,   Spent sometime to mark this as solution if this resolves your issue. ... View more

Thanks You ... View more

Set the value of the dfs.webhdfs.enabled property in hdfs-site.xml to true. <property> <name>dfs.webhdfs.enabled</name> <value>true</value> </property> Create an HTTP service user principal. kadmin: addprinc -randkey HTTP/$<Fully_Qualified_Domain_Name>@$<Realm_Name>.COM where: Fully_Qualified_Domain_Name: Host where the NameNode is deployed. Realm_Name: Name of your Kerberos realm. Create a keytab file for the HTTP principal. kadmin: xst -norandkey -k /etc/security/spnego.service.keytab HTTP/$<Fully_Qualified_Domain_Name> Verify that the keytab file and the principal are associated with the correct service. klist –k -t /etc/security/spnego.service.keytab Add the dfs.web.authentication.kerberos.principal and dfs.web.authentication.kerberos.keytab properties to hdfs-site.xml. <property> <name>dfs.web.authentication.kerberos.principal</name> <value>HTTP/$<Fully_Qualified_Domain_Name>@$<Realm_Name>.COM</value> </property> <property> <name>dfs.web.authentication.kerberos.keytab</name> <value>/etc/security/spnego.service.keytab</value> </property> Restart the NameNode and the DataNodes. ... View more

Dear Jay   what to say   excellent answer , you are really one of the best here  ... View more

@ChineduLB  Are you able to get this working? ... View more