You are viewing a plain text version of this content. The canonical link for it is here.
Posted to user@storm.apache.org by Anirudh Chhangani <an...@riptideio.com> on 2016/07/14 07:28:37 UTC
Error in setBolt("cassandra", new CassandraWriterBolt());
Hi,
I am relatively new to storm and wanted to ask a very trivial question, I
am facing issues while setting CassandraWriterBolt in my topology.
Code :
CassandraWriterBolt Historybolt = new
CassandraWriterBolt(async(simpleQuery(getEventHistoryQuery()).with(
all() )));
builder.setBolt("cassandra", Historybolt, 1)
.shuffleGrouping("cstar-query-stream");
Error :
Error:(43, 16) java: *no suitable method found for
setBolt(java.lang.String,org.apache.storm.cassandra.bolt.CassandraWriterBolt,int)*
method
backtype.storm.topology.TopologyBuilder.setBolt(java.lang.String,backtype.storm.topology.IRichBolt,java.lang.Number)
is not applicable
(argument mismatch;
org.apache.storm.cassandra.bolt.CassandraWriterBolt cannot be converted to
backtype.storm.topology.IRichBolt)
method
backtype.storm.topology.TopologyBuilder.setBolt(java.lang.String,backtype.storm.topology.IBasicBolt,java.lang.Number)
is not applicable
(argument mismatch;
org.apache.storm.cassandra.bolt.CassandraWriterBolt cannot be converted to
backtype.storm.topology.IBasicBolt)
DependencyVersion:
storm-core : 0.10.1
storm-cassandra : 1.0.1
Any help here would be appreciated
Thanks
--
Anirudh Chhangani
RiptideIO
Re: Error in setBolt("cassandra", new CassandraWriterBolt());
Posted by Anirudh Chhangani <an...@riptideio.com>.
Thanks a lot guys, wasn't aware of the API changes.
On Thu, Jul 14, 2016 at 2:39 PM, Xin Wang <da...@gmail.com> wrote:
> recommend upgrading both storm-core and storm-cassandra to 1.0.1. and
> refer to the NOTE in 1.0.1 release docs:
> http://storm.apache.org/releases/1.0.1/index.html
>
> 2016-07-14 16:42 GMT+08:00 Jungtaek Lim <ka...@gmail.com>:
>
>> Sorry forgot to paste: backtype.storm -> org.apache.storm
>>
>> 2016년 7월 14일 (목) 오후 5:41, Jungtaek Lim <ka...@gmail.com>님이 작성:
>>
>>> Hi Anirudh,
>>>
>>> Storm 1.x is not backward compatible with Storm 0.x since package name
>>> is changed from "backtype.storm" to " across whole classes.
>>> Storm 1.x provides tool (like a hack) to play with topology which are
>>> compiled with Storm 0.x, but not opposite way.
>>>
>>> You need to upgrade your Storm cluster to 1.x to use storm-cassandra. Or
>>> you could port storm-cassandra to 0.10 manually which I think is not that
>>> hard but not recommended.
>>>
>>> Thanks,
>>> Jungtaek Lim (HeartSaVioR)
>>>
>>> 2016년 7월 14일 (목) 오후 4:28, Anirudh Chhangani <an...@riptideio.com>님이
>>> 작성:
>>>
>>>> Hi,
>>>>
>>>> I am relatively new to storm and wanted to ask a very trivial question,
>>>> I am facing issues while setting CassandraWriterBolt in my topology.
>>>>
>>>> Code :
>>>>
>>>> CassandraWriterBolt Historybolt = new CassandraWriterBolt(async(simpleQuery(getEventHistoryQuery()).with( all() )));
>>>> builder.setBolt("cassandra", Historybolt, 1)
>>>> .shuffleGrouping("cstar-query-stream");
>>>>
>>>> Error :
>>>>
>>>> Error:(43, 16) java: *no suitable method found for
>>>> setBolt(java.lang.String,org.apache.storm.cassandra.bolt.CassandraWriterBolt,int)*
>>>> method
>>>> backtype.storm.topology.TopologyBuilder.setBolt(java.lang.String,backtype.storm.topology.IRichBolt,java.lang.Number)
>>>> is not applicable
>>>> (argument mismatch;
>>>> org.apache.storm.cassandra.bolt.CassandraWriterBolt cannot be converted to
>>>> backtype.storm.topology.IRichBolt)
>>>> method
>>>> backtype.storm.topology.TopologyBuilder.setBolt(java.lang.String,backtype.storm.topology.IBasicBolt,java.lang.Number)
>>>> is not applicable
>>>> (argument mismatch;
>>>> org.apache.storm.cassandra.bolt.CassandraWriterBolt cannot be converted to
>>>> backtype.storm.topology.IBasicBolt)
>>>>
>>>> DependencyVersion:
>>>>
>>>> storm-core : 0.10.1
>>>> storm-cassandra : 1.0.1
>>>>
>>>> Any help here would be appreciated
>>>> Thanks
>>>>
>>>> --
>>>> Anirudh Chhangani
>>>> RiptideIO
>>>>
>>>
>
--
Anirudh Chhangani
RiptideIO
Re: Error in setBolt("cassandra", new CassandraWriterBolt());
Posted by Xin Wang <da...@gmail.com>.
recommend upgrading both storm-core and storm-cassandra to 1.0.1. and refer
to the NOTE in 1.0.1 release docs:
http://storm.apache.org/releases/1.0.1/index.html
2016-07-14 16:42 GMT+08:00 Jungtaek Lim <ka...@gmail.com>:
> Sorry forgot to paste: backtype.storm -> org.apache.storm
>
> 2016년 7월 14일 (목) 오후 5:41, Jungtaek Lim <ka...@gmail.com>님이 작성:
>
>> Hi Anirudh,
>>
>> Storm 1.x is not backward compatible with Storm 0.x since package name is
>> changed from "backtype.storm" to " across whole classes.
>> Storm 1.x provides tool (like a hack) to play with topology which are
>> compiled with Storm 0.x, but not opposite way.
>>
>> You need to upgrade your Storm cluster to 1.x to use storm-cassandra. Or
>> you could port storm-cassandra to 0.10 manually which I think is not that
>> hard but not recommended.
>>
>> Thanks,
>> Jungtaek Lim (HeartSaVioR)
>>
>> 2016년 7월 14일 (목) 오후 4:28, Anirudh Chhangani <an...@riptideio.com>님이 작성:
>>
>>> Hi,
>>>
>>> I am relatively new to storm and wanted to ask a very trivial question,
>>> I am facing issues while setting CassandraWriterBolt in my topology.
>>>
>>> Code :
>>>
>>> CassandraWriterBolt Historybolt = new CassandraWriterBolt(async(simpleQuery(getEventHistoryQuery()).with( all() )));
>>> builder.setBolt("cassandra", Historybolt, 1)
>>> .shuffleGrouping("cstar-query-stream");
>>>
>>> Error :
>>>
>>> Error:(43, 16) java: *no suitable method found for
>>> setBolt(java.lang.String,org.apache.storm.cassandra.bolt.CassandraWriterBolt,int)*
>>> method
>>> backtype.storm.topology.TopologyBuilder.setBolt(java.lang.String,backtype.storm.topology.IRichBolt,java.lang.Number)
>>> is not applicable
>>> (argument mismatch;
>>> org.apache.storm.cassandra.bolt.CassandraWriterBolt cannot be converted to
>>> backtype.storm.topology.IRichBolt)
>>> method
>>> backtype.storm.topology.TopologyBuilder.setBolt(java.lang.String,backtype.storm.topology.IBasicBolt,java.lang.Number)
>>> is not applicable
>>> (argument mismatch;
>>> org.apache.storm.cassandra.bolt.CassandraWriterBolt cannot be converted to
>>> backtype.storm.topology.IBasicBolt)
>>>
>>> DependencyVersion:
>>>
>>> storm-core : 0.10.1
>>> storm-cassandra : 1.0.1
>>>
>>> Any help here would be appreciated
>>> Thanks
>>>
>>> --
>>> Anirudh Chhangani
>>> RiptideIO
>>>
>>
Re: Error in setBolt("cassandra", new CassandraWriterBolt());
Posted by Jungtaek Lim <ka...@gmail.com>.
Sorry forgot to paste: backtype.storm -> org.apache.storm
2016년 7월 14일 (목) 오후 5:41, Jungtaek Lim <ka...@gmail.com>님이 작성:
> Hi Anirudh,
>
> Storm 1.x is not backward compatible with Storm 0.x since package name is
> changed from "backtype.storm" to " across whole classes.
> Storm 1.x provides tool (like a hack) to play with topology which are
> compiled with Storm 0.x, but not opposite way.
>
> You need to upgrade your Storm cluster to 1.x to use storm-cassandra. Or
> you could port storm-cassandra to 0.10 manually which I think is not that
> hard but not recommended.
>
> Thanks,
> Jungtaek Lim (HeartSaVioR)
>
> 2016년 7월 14일 (목) 오후 4:28, Anirudh Chhangani <an...@riptideio.com>님이 작성:
>
>> Hi,
>>
>> I am relatively new to storm and wanted to ask a very trivial question, I
>> am facing issues while setting CassandraWriterBolt in my topology.
>>
>> Code :
>>
>> CassandraWriterBolt Historybolt = new CassandraWriterBolt(async(simpleQuery(getEventHistoryQuery()).with( all() )));
>> builder.setBolt("cassandra", Historybolt, 1)
>> .shuffleGrouping("cstar-query-stream");
>>
>> Error :
>>
>> Error:(43, 16) java: *no suitable method found for
>> setBolt(java.lang.String,org.apache.storm.cassandra.bolt.CassandraWriterBolt,int)*
>> method
>> backtype.storm.topology.TopologyBuilder.setBolt(java.lang.String,backtype.storm.topology.IRichBolt,java.lang.Number)
>> is not applicable
>> (argument mismatch;
>> org.apache.storm.cassandra.bolt.CassandraWriterBolt cannot be converted to
>> backtype.storm.topology.IRichBolt)
>> method
>> backtype.storm.topology.TopologyBuilder.setBolt(java.lang.String,backtype.storm.topology.IBasicBolt,java.lang.Number)
>> is not applicable
>> (argument mismatch;
>> org.apache.storm.cassandra.bolt.CassandraWriterBolt cannot be converted to
>> backtype.storm.topology.IBasicBolt)
>>
>> DependencyVersion:
>>
>> storm-core : 0.10.1
>> storm-cassandra : 1.0.1
>>
>> Any help here would be appreciated
>> Thanks
>>
>> --
>> Anirudh Chhangani
>> RiptideIO
>>
>
Re: Error in setBolt("cassandra", new CassandraWriterBolt());
Posted by Jungtaek Lim <ka...@gmail.com>.
Hi Anirudh,
Storm 1.x is not backward compatible with Storm 0.x since package name is
changed from "backtype.storm" to " across whole classes.
Storm 1.x provides tool (like a hack) to play with topology which are
compiled with Storm 0.x, but not opposite way.
You need to upgrade your Storm cluster to 1.x to use storm-cassandra. Or
you could port storm-cassandra to 0.10 manually which I think is not that
hard but not recommended.
Thanks,
Jungtaek Lim (HeartSaVioR)
2016년 7월 14일 (목) 오후 4:28, Anirudh Chhangani <an...@riptideio.com>님이 작성:
> Hi,
>
> I am relatively new to storm and wanted to ask a very trivial question, I
> am facing issues while setting CassandraWriterBolt in my topology.
>
> Code :
>
> CassandraWriterBolt Historybolt = new CassandraWriterBolt(async(simpleQuery(getEventHistoryQuery()).with( all() )));
> builder.setBolt("cassandra", Historybolt, 1)
> .shuffleGrouping("cstar-query-stream");
>
> Error :
>
> Error:(43, 16) java: *no suitable method found for
> setBolt(java.lang.String,org.apache.storm.cassandra.bolt.CassandraWriterBolt,int)*
> method
> backtype.storm.topology.TopologyBuilder.setBolt(java.lang.String,backtype.storm.topology.IRichBolt,java.lang.Number)
> is not applicable
> (argument mismatch;
> org.apache.storm.cassandra.bolt.CassandraWriterBolt cannot be converted to
> backtype.storm.topology.IRichBolt)
> method
> backtype.storm.topology.TopologyBuilder.setBolt(java.lang.String,backtype.storm.topology.IBasicBolt,java.lang.Number)
> is not applicable
> (argument mismatch;
> org.apache.storm.cassandra.bolt.CassandraWriterBolt cannot be converted to
> backtype.storm.topology.IBasicBolt)
>
> DependencyVersion:
>
> storm-core : 0.10.1
> storm-cassandra : 1.0.1
>
> Any help here would be appreciated
> Thanks
>
> --
> Anirudh Chhangani
> RiptideIO
>
Re: Error in setBolt("cassandra", new CassandraWriterBolt());
Posted by Satish Duggana <sa...@gmail.com>.
Hi,
Can you try storm-core and storm-cassandra with the same versions?
Thanks,
Satish.
On Thu, Jul 14, 2016 at 12:58 PM, Anirudh Chhangani <an...@riptideio.com>
wrote:
> Hi,
>
> I am relatively new to storm and wanted to ask a very trivial question, I
> am facing issues while setting CassandraWriterBolt in my topology.
>
> Code :
>
> CassandraWriterBolt Historybolt = new CassandraWriterBolt(async(simpleQuery(getEventHistoryQuery()).with( all() )));
> builder.setBolt("cassandra", Historybolt, 1)
> .shuffleGrouping("cstar-query-stream");
>
> Error :
>
> Error:(43, 16) java: *no suitable method found for
> setBolt(java.lang.String,org.apache.storm.cassandra.bolt.CassandraWriterBolt,int)*
> method
> backtype.storm.topology.TopologyBuilder.setBolt(java.lang.String,backtype.storm.topology.IRichBolt,java.lang.Number)
> is not applicable
> (argument mismatch;
> org.apache.storm.cassandra.bolt.CassandraWriterBolt cannot be converted to
> backtype.storm.topology.IRichBolt)
> method
> backtype.storm.topology.TopologyBuilder.setBolt(java.lang.String,backtype.storm.topology.IBasicBolt,java.lang.Number)
> is not applicable
> (argument mismatch;
> org.apache.storm.cassandra.bolt.CassandraWriterBolt cannot be converted to
> backtype.storm.topology.IBasicBolt)
>
> DependencyVersion:
>
> storm-core : 0.10.1
> storm-cassandra : 1.0.1
>
> Any help here would be appreciated
> Thanks
>
> --
> Anirudh Chhangani
> RiptideIO
>