Using Memcached with Trident

[Thilina Rathnayake <th...@gmail.com>]

Hi All,

I can't configure Memcached to be used with trident. It will be a big help
If you
can tell me what I am doing wrong.

I want to run my topology in distributed mode, not in the local mode.

Here is what I have done:

1. Installed `Memcached` using `sudo apt-get install memcached`.
2. Added `trident-memcached`[1] as a dependency in my `pom.xml` file.
3. Wrote a trident topology (with a DRPC stream).
4. Run zookeeper, nimbus, supervisor(in 3 nodes), drpc server and memcached
server.
5. Submit the topology

But when I submit my topology, I can see the following error in the worker
nodes.

2015-08-05 09:17:30 b.s.util [ERROR] Async loop died!
java.lang.AbstractMethodError:
trident.memcached.MemcachedState$Factory.makeState(Ljava/util/Map;Lbacktype/storm/task/IMetricsContext;II)Lstorm/trident/state/State;
at storm.trident.planner.SubtopologyBolt.prepare(SubtopologyBolt.java:69)
~[storm-core-0.9.2-incubating.jar:0.9.2-incubating]
at
storm.trident.topology.TridentBoltExecutor.prepare(TridentBoltExecutor.java:231)
~[storm-core-0.9.2-incubating.jar:0.9.2-incubating]
at
backtype.storm.daemon.executor$fn__5641$fn__5653.invoke(executor.clj:690)
~[storm-core-0.9.2-incubating.jar:0.9.2-incubating]
at backtype.storm.util$async_loop$fn__457.invoke(util.clj:429)
~[storm-core-0.9.2-incubating.jar:0.9.2-incubating]
at clojure.lang.AFn.run(AFn.java:24) [clojure-1.5.1.jar:na]
at java.lang.Thread.run(Thread.java:745) [na:1.7.0_80]
2015-08-05 09:17:30 b.s.d.executor [ERROR]
java.lang.AbstractMethodError:
trident.memcached.MemcachedState$Factory.makeState(Ljava/util/Map;Lbacktype/storm/task/IMetricsContext;II)Lstorm/trident/state/State;
at storm.trident.planner.SubtopologyBolt.prepare(SubtopologyBolt.java:69)
~[storm-core-0.9.2-incubating.jar:0.9.2-incubating]
at
storm.trident.topology.TridentBoltExecutor.prepare(TridentBoltExecutor.java:231)
~[storm-core-0.9.2-incubating.jar:0.9.2-incubating]
at
backtype.storm.daemon.executor$fn__5641$fn__5653.invoke(executor.clj:690)
~[storm-core-0.9.2-incubating.jar:0.9.2-incubating]
at backtype.storm.util$async_loop$fn__457.invoke(util.clj:429)
~[storm-core-0.9.2-incubating.jar:0.9.2-incubating]
at clojure.lang.AFn.run(AFn.java:24) [clojure-1.5.1.jar:na]
at java.lang.Thread.run(Thread.java:745) [na:1.7.0_80]

I have attached my code for your kind reference.

Thanks in advance.

Regards,
Thilina