我在storm拓扑配置中使用自定义序列化程序，如下所示：
config.put(Config.TOPOLOGY_FALL_BACK_ON_JAVA_SERIALIZATION, false);
config.registerSerialization(ObjectNode.class, ObjectNodeSerializer.class);objectnodeserializer.class在准备过程中得到了很好的示例化，但在拓扑执行过程中从未调用序列化和反序列化方法。
我在storm拓扑配置中使用自定义序列化程序，如下所示：
config.put(Config.TOPOLOGY_FALL_BACK_ON_JAVA_SERIALIZATION, false);
config.registerSerialization(ObjectNode.class, ObjectNodeSerializer.class);objectnodeserializer.class在准备过程中得到了很好的示例化，但在拓扑执行过程中从未调用序列化和反序列化方法。
1条答案
按热度按时间gj3fmq9x1#
默认情况下，当storm将任何元组传递给同一个worker中的bolt时，它不会序列化任何元组。如果您只有一个工作进程（在本地集群模式下运行？）并且想要测试序列化，请设置以下配置
topology.testing.always.try.serialize: true