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 <kabh...@gmail.com>:
> Sorry forgot to paste: backtype.storm -> org.apache.storm
>
> 2016년 7월 14일 (목) 오후 5:41, Jungtaek Lim <kabh...@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 <anir...@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
>>>
>>
