Not able to connect to hive with logstash input

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.

@magnusbaeck Can you help with above?

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

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