Thanks a lot guys, wasn't aware of the API changes. On Thu, Jul 14, 2016 at 2:39 PM, Xin Wang <[email protected]> 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 <[email protected]>: > >> 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 >>>> >>> > -- Anirudh Chhangani RiptideIO
