fixed null handling in Livy
@@ -223,7 +223,6 @@ public class LivyRestModelTransformer {
List<Object> newValues = Lists.newArrayListWithCapacity(tqr.getColumns().size());
while (valueNodes.hasNext()) {
JsonNode value = valueNodes.next();
-
// extract values according to how jackson deserialized it
if (value.isObject()) {
// spark treats an array as a struct with a single field "values" ...
@@ -255,6 +254,8 @@ public class LivyRestModelTransformer {
} else if (value.isNumber()) {
// easy peasy.. it's just a number
newValues.add(value.numberValue());
+ } else if (value.isNull()) {
+ newValues.add(null);
} else if (value.isValueNode()) {
// value Nodes we just get the raw text..
newValues.add(value.asText());
