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 <[email protected]>님이 작성: > 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 >
