You are viewing a plain text version of this content. The canonical link for it is here.
Posted to user@storm.apache.org by Venkatesh Bodapati <ve...@inndata.in> on 2016/06/22 07:40:49 UTC
java.lang.NoSuchMethodError: org.apache.thrift.protocol.TProtocol.getScheme()Ljava/lang/Class
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.
Re: java.lang.NoSuchMethodError: org.apache.thrift.protocol.TProtocol.getScheme()Ljava/lang/Class
Posted by Venkatesh Bodapati <ve...@inndata.in>.
Hi Florin,
Thanks for your quick reply , it will works for me.
Thanks & Regards,
venkatesh
On Mon, Jun 27, 2016 at 1:14 PM, Spico Florin <sp...@gmail.com> wrote:
> Hi!
> Storm uses it own thrift library
> (org.apache.thrift:libthrift:pom:0.9.2). When you submit on the cluster
> you'll have two different versions of Thrift (0.9.3 yours and 0.9.2 from
> storm) loaded in the classloader.
> Solution:
> 1. Exclude the the thrift version 0.9.3 from the maven dependency (see
> what library refers to it and use <exclusions><exclusion> maven) .
> 2. set the the storm-core library as "compile" scope dependency for maven
> (see <scope> element fro dependency).
> I hope that it helps.
> Regards,
> Florin
>
>
> On Mon, Jun 27, 2016 at 9:22 AM, Venkatesh Bodapati <
> venkatesh.bodapati@inndata.in> wrote:
>
>> Hi Florin, Thanks for your reply.
>>
>> These are the jars i used in mylib :
>> antlr4-4.5.1-1.jar
>> antlr4-runtime-4.5.1-1.jar
>> asm-4.0.jar
>> carbonite-1.4.0.jar
>> chill-java-0.3.5.jar
>> clj-stacktrace-0.2.2.jar
>> clj-time-0.4.1.jar
>> clojure-1.5.1.jar
>> clout-1.0.1.jar
>> commons-codec-1.6.jar
>> commons-exec-1.1.jar
>> commons-fileupload-1.2.1.jar
>> commons-io-2.4.jar
>> commons-lang-2.5.jar
>> commons-logging-1.1.3.jar
>> commons-logging-api-1.1.jar
>> compojure-1.1.3.jar
>> core.incubator-0.1.0.jar
>> curator-client-2.6.0.jar
>> curator-framework-2.6.0.jar
>> derby-10.12.1.1.jar
>> disruptor-2.10.1.jar
>> guava-11.0.2.jar
>> hadoop-client-2.6.0.jar
>> hadoop-mapreduce-client-core-2.6.0.jar
>> hiccup-0.3.6.jar
>> hive-exec-0.8.0.jar
>> jetty-util-6.1.26.jar
>> jgrapht-core-0.9.0.jar
>> jline-2.11.jar
>> joda-time-2.0.jar
>> json-simple-1.1.1.jar
>> junit-4.3.jar
>> kafka_2.11-0.8.2.1.jar
>> kafka_2.11-0.8.2.1-javadoc.jar
>> kafka_2.11-0.8.2.1-scaladoc.jar
>> kafka_2.11-0.8.2.1-sources.jar
>> kafka_2.11-0.8.2.1-test.jar
>> kafka-clients-0.8.2.1.jar
>> kryo-2.21.jar
>> logback-classic-1.0.13.jar
>> logback-core-1.0.13.jar
>> math.numeric-tower-0.0.1.jar
>> metrics-core-2.2.0.jar
>> minlog-1.2.jar
>> objenesis-1.2.jar
>> reflectasm-1.07-shaded.jar
>> ring-core-1.1.5.jar
>> ring-devel-0.3.11.jar
>> ring-jetty-adapter-0.3.11.jar
>> ring-servlet-0.3.11.jar
>> scala-library-2.11.5.jar
>> servlet-api-2.5.jar
>> slf4j-api-1.7.5.jar
>> snakeyaml-1.11.jar
>> snappy-java-1.1.1.6.jar
>> storm-core-0.9.5.jar
>> tools.cli-0.2.4.jar
>> tools.logging-0.2.3.jar
>> tools.macro-0.1.0.jar
>> zkclient-0.3.jar
>> zookeeper-3.4.6.jar
>> gson-2.2.4.jar
>> java-json.jar
>> activation-1.1.jar
>> storm-core-0.9.1-incubating.jar
>> log4j-1.2.17.jar
>> mockito-all-1.8.5.jar
>> org.apache.commons.collections.jar
>> org.apache.commons.httpclient.jar
>> org.apache.commons.logging-1.1.1.jar
>> org.json-20120521.jar
>> protobuf-java-2.5.0.jar
>> kafka_2.11-0.8.2.1/libs/jopt-simple-3.2.jar
>> kafka_2.11-0.8.2.1/libs/scala-parser-combinators_2.11-1.0.2.jar
>> kafka_2.11-0.8.2.1/libs/scala-xml_2.11-1.0.2.jar
>> httpcore-4.4.jar
>> hadoop-auth-2.7.2.jar
>> hadoop-streaming-2.7.2.jar
>> htrace-core-3.1.0-incubating.jar
>> hadoop-nfs-2.7.2.jar
>> hive-cli-1.2.1.jar
>> hive-common-1.2.1.jar
>> hive-contrib-1.2.1.jar
>> hive-exec-1.2.1.jar
>> hive-jdbc-1.2.1.jar
>> hive-metastore-1.2.1.jar
>> hive-serde-1.2.1.jar
>> hive-service-1.2.1.jar
>> hive-testutils-1.2.1.jar
>> mysql-connector-java-5.1.35-bin.jar
>> hadoop-common-2.7.1.jar
>> httpclient-4.5.jar
>> commons-beanutils-core-1.8.0.jar
>> commons-collections-3.2.1.jar
>> commons-configuration-1.6.jar
>> commons-httpclient-3.0.1.jar
>> libthrift-0.9.3.jar
>>
>> i am using only one libthrift jar that is libthrift-0.9.3 jar now but i
>> got the same error, like this " java.lang.NoSuchMethodError:
>> org.apache.thrift.protocol.TProtocol.getScheme()Ljava/lang/Class".
>>
>> Thanks & Regards,
>> venkatesh
>>
>> On Thu, Jun 23, 2016 at 2:55 PM, Spico Florin <sp...@gmail.com>
>> wrote:
>>
>>> Hi!
>>> Please check out your classpath (maven or gradle dependencies). It
>>> seems that you are using two versions of Thrift library protocol.
>>> Regards,
>>> Florin
>>>
>>> On Wed, Jun 22, 2016 at 10:40 AM, Venkatesh Bodapati <
>>> venkatesh.bodapati@inndata.in> wrote:
>>>
>>>> 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.
>>>>
>>>
>>>
>>
>
Re: java.lang.NoSuchMethodError: org.apache.thrift.protocol.TProtocol.getScheme()Ljava/lang/Class
Posted by Spico Florin <sp...@gmail.com>.
Hi!
Storm uses it own thrift library (org.apache.thrift:libthrift:pom:0.9.2).
When you submit on the cluster you'll have two different versions of Thrift
(0.9.3 yours and 0.9.2 from storm) loaded in the classloader.
Solution:
1. Exclude the the thrift version 0.9.3 from the maven dependency (see what
library refers to it and use <exclusions><exclusion> maven) .
2. set the the storm-core library as "compile" scope dependency for maven
(see <scope> element fro dependency).
I hope that it helps.
Regards,
Florin
On Mon, Jun 27, 2016 at 9:22 AM, Venkatesh Bodapati <
venkatesh.bodapati@inndata.in> wrote:
> Hi Florin, Thanks for your reply.
>
> These are the jars i used in mylib :
> antlr4-4.5.1-1.jar
> antlr4-runtime-4.5.1-1.jar
> asm-4.0.jar
> carbonite-1.4.0.jar
> chill-java-0.3.5.jar
> clj-stacktrace-0.2.2.jar
> clj-time-0.4.1.jar
> clojure-1.5.1.jar
> clout-1.0.1.jar
> commons-codec-1.6.jar
> commons-exec-1.1.jar
> commons-fileupload-1.2.1.jar
> commons-io-2.4.jar
> commons-lang-2.5.jar
> commons-logging-1.1.3.jar
> commons-logging-api-1.1.jar
> compojure-1.1.3.jar
> core.incubator-0.1.0.jar
> curator-client-2.6.0.jar
> curator-framework-2.6.0.jar
> derby-10.12.1.1.jar
> disruptor-2.10.1.jar
> guava-11.0.2.jar
> hadoop-client-2.6.0.jar
> hadoop-mapreduce-client-core-2.6.0.jar
> hiccup-0.3.6.jar
> hive-exec-0.8.0.jar
> jetty-util-6.1.26.jar
> jgrapht-core-0.9.0.jar
> jline-2.11.jar
> joda-time-2.0.jar
> json-simple-1.1.1.jar
> junit-4.3.jar
> kafka_2.11-0.8.2.1.jar
> kafka_2.11-0.8.2.1-javadoc.jar
> kafka_2.11-0.8.2.1-scaladoc.jar
> kafka_2.11-0.8.2.1-sources.jar
> kafka_2.11-0.8.2.1-test.jar
> kafka-clients-0.8.2.1.jar
> kryo-2.21.jar
> logback-classic-1.0.13.jar
> logback-core-1.0.13.jar
> math.numeric-tower-0.0.1.jar
> metrics-core-2.2.0.jar
> minlog-1.2.jar
> objenesis-1.2.jar
> reflectasm-1.07-shaded.jar
> ring-core-1.1.5.jar
> ring-devel-0.3.11.jar
> ring-jetty-adapter-0.3.11.jar
> ring-servlet-0.3.11.jar
> scala-library-2.11.5.jar
> servlet-api-2.5.jar
> slf4j-api-1.7.5.jar
> snakeyaml-1.11.jar
> snappy-java-1.1.1.6.jar
> storm-core-0.9.5.jar
> tools.cli-0.2.4.jar
> tools.logging-0.2.3.jar
> tools.macro-0.1.0.jar
> zkclient-0.3.jar
> zookeeper-3.4.6.jar
> gson-2.2.4.jar
> java-json.jar
> activation-1.1.jar
> storm-core-0.9.1-incubating.jar
> log4j-1.2.17.jar
> mockito-all-1.8.5.jar
> org.apache.commons.collections.jar
> org.apache.commons.httpclient.jar
> org.apache.commons.logging-1.1.1.jar
> org.json-20120521.jar
> protobuf-java-2.5.0.jar
> kafka_2.11-0.8.2.1/libs/jopt-simple-3.2.jar
> kafka_2.11-0.8.2.1/libs/scala-parser-combinators_2.11-1.0.2.jar
> kafka_2.11-0.8.2.1/libs/scala-xml_2.11-1.0.2.jar
> httpcore-4.4.jar
> hadoop-auth-2.7.2.jar
> hadoop-streaming-2.7.2.jar
> htrace-core-3.1.0-incubating.jar
> hadoop-nfs-2.7.2.jar
> hive-cli-1.2.1.jar
> hive-common-1.2.1.jar
> hive-contrib-1.2.1.jar
> hive-exec-1.2.1.jar
> hive-jdbc-1.2.1.jar
> hive-metastore-1.2.1.jar
> hive-serde-1.2.1.jar
> hive-service-1.2.1.jar
> hive-testutils-1.2.1.jar
> mysql-connector-java-5.1.35-bin.jar
> hadoop-common-2.7.1.jar
> httpclient-4.5.jar
> commons-beanutils-core-1.8.0.jar
> commons-collections-3.2.1.jar
> commons-configuration-1.6.jar
> commons-httpclient-3.0.1.jar
> libthrift-0.9.3.jar
>
> i am using only one libthrift jar that is libthrift-0.9.3 jar now but i
> got the same error, like this " java.lang.NoSuchMethodError:
> org.apache.thrift.protocol.TProtocol.getScheme()Ljava/lang/Class".
>
> Thanks & Regards,
> venkatesh
>
> On Thu, Jun 23, 2016 at 2:55 PM, Spico Florin <sp...@gmail.com>
> wrote:
>
>> Hi!
>> Please check out your classpath (maven or gradle dependencies). It
>> seems that you are using two versions of Thrift library protocol.
>> Regards,
>> Florin
>>
>> On Wed, Jun 22, 2016 at 10:40 AM, Venkatesh Bodapati <
>> venkatesh.bodapati@inndata.in> wrote:
>>
>>> 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.
>>>
>>
>>
>
Re: java.lang.NoSuchMethodError: org.apache.thrift.protocol.TProtocol.getScheme()Ljava/lang/Class
Posted by Venkatesh Bodapati <ve...@inndata.in>.
Hi Florin, Thanks for your reply.
These are the jars i used in mylib :
antlr4-4.5.1-1.jar
antlr4-runtime-4.5.1-1.jar
asm-4.0.jar
carbonite-1.4.0.jar
chill-java-0.3.5.jar
clj-stacktrace-0.2.2.jar
clj-time-0.4.1.jar
clojure-1.5.1.jar
clout-1.0.1.jar
commons-codec-1.6.jar
commons-exec-1.1.jar
commons-fileupload-1.2.1.jar
commons-io-2.4.jar
commons-lang-2.5.jar
commons-logging-1.1.3.jar
commons-logging-api-1.1.jar
compojure-1.1.3.jar
core.incubator-0.1.0.jar
curator-client-2.6.0.jar
curator-framework-2.6.0.jar
derby-10.12.1.1.jar
disruptor-2.10.1.jar
guava-11.0.2.jar
hadoop-client-2.6.0.jar
hadoop-mapreduce-client-core-2.6.0.jar
hiccup-0.3.6.jar
hive-exec-0.8.0.jar
jetty-util-6.1.26.jar
jgrapht-core-0.9.0.jar
jline-2.11.jar
joda-time-2.0.jar
json-simple-1.1.1.jar
junit-4.3.jar
kafka_2.11-0.8.2.1.jar
kafka_2.11-0.8.2.1-javadoc.jar
kafka_2.11-0.8.2.1-scaladoc.jar
kafka_2.11-0.8.2.1-sources.jar
kafka_2.11-0.8.2.1-test.jar
kafka-clients-0.8.2.1.jar
kryo-2.21.jar
logback-classic-1.0.13.jar
logback-core-1.0.13.jar
math.numeric-tower-0.0.1.jar
metrics-core-2.2.0.jar
minlog-1.2.jar
objenesis-1.2.jar
reflectasm-1.07-shaded.jar
ring-core-1.1.5.jar
ring-devel-0.3.11.jar
ring-jetty-adapter-0.3.11.jar
ring-servlet-0.3.11.jar
scala-library-2.11.5.jar
servlet-api-2.5.jar
slf4j-api-1.7.5.jar
snakeyaml-1.11.jar
snappy-java-1.1.1.6.jar
storm-core-0.9.5.jar
tools.cli-0.2.4.jar
tools.logging-0.2.3.jar
tools.macro-0.1.0.jar
zkclient-0.3.jar
zookeeper-3.4.6.jar
gson-2.2.4.jar
java-json.jar
activation-1.1.jar
storm-core-0.9.1-incubating.jar
log4j-1.2.17.jar
mockito-all-1.8.5.jar
org.apache.commons.collections.jar
org.apache.commons.httpclient.jar
org.apache.commons.logging-1.1.1.jar
org.json-20120521.jar
protobuf-java-2.5.0.jar
kafka_2.11-0.8.2.1/libs/jopt-simple-3.2.jar
kafka_2.11-0.8.2.1/libs/scala-parser-combinators_2.11-1.0.2.jar
kafka_2.11-0.8.2.1/libs/scala-xml_2.11-1.0.2.jar
httpcore-4.4.jar
hadoop-auth-2.7.2.jar
hadoop-streaming-2.7.2.jar
htrace-core-3.1.0-incubating.jar
hadoop-nfs-2.7.2.jar
hive-cli-1.2.1.jar
hive-common-1.2.1.jar
hive-contrib-1.2.1.jar
hive-exec-1.2.1.jar
hive-jdbc-1.2.1.jar
hive-metastore-1.2.1.jar
hive-serde-1.2.1.jar
hive-service-1.2.1.jar
hive-testutils-1.2.1.jar
mysql-connector-java-5.1.35-bin.jar
hadoop-common-2.7.1.jar
httpclient-4.5.jar
commons-beanutils-core-1.8.0.jar
commons-collections-3.2.1.jar
commons-configuration-1.6.jar
commons-httpclient-3.0.1.jar
libthrift-0.9.3.jar
i am using only one libthrift jar that is libthrift-0.9.3 jar now but i
got the same error, like this " java.lang.NoSuchMethodError:
org.apache.thrift.protocol.TProtocol.getScheme()Ljava/lang/Class".
Thanks & Regards,
venkatesh
On Thu, Jun 23, 2016 at 2:55 PM, Spico Florin <sp...@gmail.com> wrote:
> Hi!
> Please check out your classpath (maven or gradle dependencies). It seems
> that you are using two versions of Thrift library protocol.
> Regards,
> Florin
>
> On Wed, Jun 22, 2016 at 10:40 AM, Venkatesh Bodapati <
> venkatesh.bodapati@inndata.in> wrote:
>
>> 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.
>>
>
>
Re: java.lang.NoSuchMethodError: org.apache.thrift.protocol.TProtocol.getScheme()Ljava/lang/Class
Posted by Spico Florin <sp...@gmail.com>.
Hi!
Please check out your classpath (maven or gradle dependencies). It seems
that you are using two versions of Thrift library protocol.
Regards,
Florin
On Wed, Jun 22, 2016 at 10:40 AM, Venkatesh Bodapati <
venkatesh.bodapati@inndata.in> wrote:
> 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.
>