Пользовательский сериализатор в Apache Storm 1.1.0

Question

Я использую пользовательский сериализатор в конфигурации топологии Storm следующим образом:

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

ObjectNodeSerializer.class хорошо создается во время подготовки болтов, но методы сериализации и десериализации никогда не вызываются во время выполнения топологии.

Answer 1

По умолчанию Storm не будет сериализовать любой кортеж, когда он передает его болтам в пределах одного и того же Worker. Если у вас есть только один рабочий процесс (работает в режиме локального кластера?) И вы хотите проверить сериализацию, установите следующую конфигурацию

topology.testing.always.try.serialize: true