Merge pull request #152 from Stratio/fix/DECISION-271_null_values_act…

…ions [DECISION-271] Fixed deserialization of null values in Action requests
Stratio · Mar 31, 2016 · e7dfc97 · e7dfc97
2 parents e477d92 + ab95327
commit e7dfc97
Showing 1 changed file with 10 additions and 3 deletions.
diff --git a/engine/src/main/java/com/stratio/decision/serializer/impl/JavaToAvroSerializer.java b/engine/src/main/java/com/stratio/decision/serializer/impl/JavaToAvroSerializer.java
@@ -60,9 +60,16 @@ public byte[] serialize(StratioStreamingMessage object) {
             ColumnType c = null;
 
             for (ColumnNameTypeValue messageColumn : object.getColumns()) {
-                c = new ColumnType(messageColumn.getColumn(), messageColumn.getValue().toString(),
-                        messageColumn.getValue()
-                                .getClass().getName());
+
+                if ( messageColumn.getValue() != null){
+
+                    c = new ColumnType(messageColumn.getColumn(), messageColumn.getValue().toString(),
+                            messageColumn.getValue().getClass().getName());
+
+                } else {
+                    c = new ColumnType(messageColumn.getColumn(), null, null);
+                }
+
                 columns.add(c);
             }