Sorry forgot to paste: backtype.storm -> org.apache.storm 2016년 7월 14일 (목) 오후 5:41, Jungtaek Lim <[email protected]>님이 작성:
> 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 >> >
