Skip to content
Browse files

Register our default serializer via defaults.xml, and throw exception…

… if bad serializer is configured
  • Loading branch information...
1 parent 9837bc4 commit ea0e7ff573bb3f61ec8c87bdd3c3d0f01546173f afeng committed Feb 10, 2013
Showing with 1 addition and 4 deletions.
  1. +1 −4 src/jvm/backtype/storm/serialization/SerializationFactory.java
View
5 src/jvm/backtype/storm/serialization/SerializationFactory.java
@@ -39,10 +39,7 @@ public static Kryo getKryo(Map conf) {
try {
Class serializerClass = Class.forName(payloadSerializerName);
Serializer serializer = resolveSerializerInstance(k, ListDelegate.class, serializerClass, conf);
- if (serializer == null)
- k.register(ListDelegate.class, new ListDelegateSerializer());
- else
- k.register(ListDelegate.class, serializer);
+ k.register(ListDelegate.class, serializer);
} catch (ClassNotFoundException ex) {
LOG.error("Could not load class in class path: " + payloadSerializerName.length(), ex);
throw new RuntimeException(ex);

0 comments on commit ea0e7ff

Please sign in to comment.
Something went wrong with that request. Please try again.