CODEWITHSUNDEEP
serializationapache-stormkryoapache-storm-topology
robynico
robynico

Reputation: 236

Custom serializer in Apache Storm 1.1.0

I use custom serializer in Storm topology config like this :

config.put(Config.TOPOLOGY_FALL_BACK_ON_JAVA_SERIALIZATION, false);
config.registerSerialization(ObjectNode.class, ObjectNodeSerializer.class);

ObjectNodeSerializer.class is well instanciated during bolts preparation but serialize and deserialize methods are never called during topology execution.

Upvotes: 0

Views: 233

Answers (1)

Re'em
Re'em

Reputation: 260

By default Storm will not serialize any tuple when it passes it to bolts within the same Worker. If you only have a single Worker process (running in local-cluster mode?) and want to test serialization, set following config

topology.testing.always.try.serialize: true

Upvotes: 1

Related Questions