I am working on storm with hive,sql,kafka. i will read data from kafkatopic and hive table, and send data to mysql and another kafkatopic.i willn't able to connect with hive from storm. i got error like this
java.lang.NoSuchMethodError: org.apache.thrift.protocol.TProtocol.getScheme()Ljava/lang/Class; at org.apache.hive.service.cli.thrift.TCLIService$OpenSession_args.write(TCLIService.java:1854) ~[hive-service-1.2.1.jar:1.2.1] at org.apache.thrift.TServiceClient.sendBase(TServiceClient.java:63) ~[hive-exec-0.8.0.jar:0.8.0] at org.apache.hive.service.cli.thrift.TCLIService$Client.send_OpenSession(TCLIService.java:150) ~[hive-service-1.2.1.jar:1.2.1] at org.apache.hive.service.cli.thrift.TCLIService$Client.OpenSession(TCLIService.java:142) ~[hive-service-1.2.1.jar:1.2.1] at org.apache.hive.jdbc.HiveConnection.openSession(HiveConnection.java:583) ~[hive-jdbc-1.2.1.jar:1.2.1] at org.apache.hive.jdbc.HiveConnection.<init>(HiveConnection.java:192) ~[hive-jdbc-1.2.1.jar:1.2.1] at org.apache.hive.jdbc.HiveDriver.connect(HiveDriver.java:105) ~[hive-jdbc-1.2.1.jar:1.2.1] at java.sql.DriverManager.getConnection(DriverManager.java:664) ~[na:1.8.0_91] at java.sql.DriverManager.getConnection(DriverManager.java:247) ~[na:1.8.0_91] at com.inndata.wirecard.kafkaspout.nextTuple(kafkaspout.java:88) ~[MysqlKafkaStream.jar:na] at backtype.storm.daemon.executor$fn__6579$fn__6594$fn__6623.invoke(executor.clj:565) ~[storm-core-0.9.5.jar:0.9.5] at backtype.storm.util$async_loop$fn__459.invoke(util.clj:463) ~[storm-core-0.9.5.jar:0.9.5] at clojure.lang.AFn.run(AFn.java:24) [clojure-1.5.1.jar:na] at java.lang.Thread.run(Thread.java:745) [na:1.8.0_91] 25802 [Thread-17-kafkaspout] ERROR backtype.storm.daemon.executor - i am using hive-1.2.1 version, storm :0.9.5 . using libthrift jar : libthrift-0.9.2.jar.I tried searching for this issue, but i can't find relevent jar.Please help me to fix this.
