fixes SchemeAsMultiScheme bug, when deserialize returns null

jasonjckn · Jan 11, 2013 · 7b21391 · 7b21391
1 parent 458b9f2
commit 7b21391
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/src/jvm/backtype/storm/spout/SchemeAsMultiScheme.java b/src/jvm/backtype/storm/spout/SchemeAsMultiScheme.java
@@ -13,7 +13,9 @@ public SchemeAsMultiScheme(Scheme scheme) {
   }
 
   @Override public Iterable<List<Object>> deserialize(final byte[] ser) {
-    return Arrays.asList(scheme.deserialize(ser));
+    List<Object> o = scheme.deserialize(ser);
+    if(o == null) return null;
+    else return Arrays.asList(o);
   }
 
   @Override public Fields getOutputFields() {