Not able to connect to hive with logstash input

Elastic Stack Logstash
1

Hi I am using below input in logstash.

input {
jdbc { jdbc_driver_library => "home/app/hive-jdbc-2.0.0.jar" jdbc_driver_class => "org.apache.hive.jdbc.HiveDriver" jdbc_connection_string => "jdbc:hive2://xxxxxxx:10000/database" jdbc_user => “user” statement => "Select * from mytable" }
}

It's throwing me the error below.

{:timestamp=>"2017-10-16T04:47:17.237000+0000", :message=>"Pipeline aborted due to error", :exception=>#<Sequel::DatabaseConnectionError: Java::JavaLang::NoClassDefFoundError: org/apache/thrift/TException>, :backtrace=>["org.apache.hive.jdbc.HiveDriver.connect(org/apache/hive/jdbc/HiveDriver.java:107)", "java.sql.DriverManager.getConnection(java/sql/DriverManager.java:664)", "java.sql.DriverManager.getConnection(java/sql/DriverManager.java:270)", "j........................}

Am I doing anything wrong? Thanks.

2

@magnusbaeck Can you help with above?

Is there any other way to do this as well? Thanks

3

This topic was automatically closed 28 days after the last reply. New replies are no longer allowed.