Nifi Unable to use Impala connection in the executor script processor,impala Jdbc connection failed

Hi! @mburgess @MattWho @SAMSAL Do you have any insights here? Thanks!

@Zainers 

Unfortunately I don't think there is enough information shared to make any suggestion here yet.

Could you share your exact NiFi version and more details around what you are trying to accomplish?  

Can you share the jython script you are using to restart NiFi?
When you say it does not work using the NiFi executor, What executor are you talking about? 
What NiFi processors are you using?
How are they configured?

Thank you,
Matt

Dear Matt,

Thank you for the Followup,  This is the jython script tested in jython on of the Nifi nodes, using the central location for using the impala jar files, and nifi was restarted to pickup the jar class from the nar location as well the customized location readable by nifi,

and in jython it works fine, and in impala it fails. we are using nifi version 1.28.1.2.1.7

jython -J-cp "/data/01/Nifi_Scripts/Nifi_Nars/*"


from java.sql import DriverManager, SQLException
from java.lang import Class


# JDBC Connection
jdbc_url = ( "jdbc:impala://xxxxrodk08.kw.xxxx.com:21000/sandbox_bi;" "AuthMech=1;" "KrbRealm=CORP.xxx.COM.xxxx;" "KrbHostFQDN=xxxxxprodk08.sw.xxxxx.com;" "KrbServiceName=impala;" "SSL=1;" "SSLTrustStore=/var/lib/cloudera-scm-agent/agent-cert/cm-auto-global_cacerts.pem;" "SSLTrustStorePwd=xxxxxxxx" )
jdbc_driver = "com.cloudera.impala.jdbc41.Driver"
Class.forName(jdbc_driver)
conn = DriverManager.getConnection(jdbc_url)

Regards

@Zainers 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.

hi @Zainers ,

you must specify the class name according to the JDBC driver (.jar) version you are using.

remember that the jar must be accessible by all hosts in the NiFi cluster.