Skip to content
Browse files

fixes SchemeAsMultiScheme bug, when deserialize returns null

  • Loading branch information...
1 parent af77ba5 commit cf7cb81451b8bf6f50d4f836b30aef8fb68570fb Jason Jackson committed
Showing with 3 additions and 1 deletion.
  1. +3 −1 src/jvm/backtype/storm/spout/SchemeAsMultiScheme.java
View
4 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() {

0 comments on commit cf7cb81

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