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 <[email protected]>
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
>

Reply via email to