Repository: incubator-apex-core Updated Branches: refs/heads/release-3.1 77a86ac2d -> e568f7918
#fixes APEX-170 handles null value for input object Project: http://git-wip-us.apache.org/repos/asf/incubator-apex-core/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-apex-core/commit/883f44f2 Tree: http://git-wip-us.apache.org/repos/asf/incubator-apex-core/tree/883f44f2 Diff: http://git-wip-us.apache.org/repos/asf/incubator-apex-core/diff/883f44f2 Branch: refs/heads/release-3.1 Commit: 883f44f2403e3046703c18e8a999469ed6e13ec2 Parents: 77a86ac Author: Ashwin Chandra Putta <[email protected]> Authored: Tue Sep 29 08:56:53 2015 -0700 Committer: Ashwin Chandra Putta <[email protected]> Committed: Tue Sep 29 08:56:53 2015 -0700 ---------------------------------------------------------------------- engine/src/main/java/com/datatorrent/stram/StringCodecs.java | 4 ++++ 1 file changed, 4 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-apex-core/blob/883f44f2/engine/src/main/java/com/datatorrent/stram/StringCodecs.java ---------------------------------------------------------------------- diff --git a/engine/src/main/java/com/datatorrent/stram/StringCodecs.java b/engine/src/main/java/com/datatorrent/stram/StringCodecs.java index eb31c3d..e8ffb58 100644 --- a/engine/src/main/java/com/datatorrent/stram/StringCodecs.java +++ b/engine/src/main/java/com/datatorrent/stram/StringCodecs.java @@ -54,6 +54,10 @@ public class StringCodecs @SuppressWarnings("unchecked") public Object convert(Class type, Object value) { + if(value == null) { + return null; + } + for (Class<?> clazz = value.getClass(); clazz != null; clazz = clazz.getSuperclass()) { Class<? extends StringCodec> codec = codecs.get(clazz); if (codec == null) {
