Merge pull request #734 from linhvo/skip-null-field

skip null field when ingest data

handler.go

@@ -1694,6 +1694,10 @@ func (h *Handler) InputJSONDataParser(req map[string]interface{}, index *Index,
 		for _, action := range field.Actions {
 			frame := action.Frame
 			timestamp := timestampFrame[action.Frame]
+			// Skip input data field values that are set to null
+			if req[field.Name] == nil {
+				continue
+			}
 			bit, err := HandleAction(action, req[field.Name], colValue, timestamp)
 			if err != nil {
 				return nil, fmt.Errorf("error handling action: %s, err: %s", action.ValueDestination, err)

handler_test.go

@@ -1274,6 +1274,16 @@ var defaultBody = `
 						}
 					 ]
 				  },
+				  {
+					 "name":"null_value",
+					 "actions":[
+						{
+						   "frame":"add-ons",
+						   "valueDestination":"value-to-row"
+
+						}
+					 ]
+				  },
 				  {
 					 "name":"time_value",
 					 "actions":[
@@ -1307,7 +1317,8 @@ func TestHandler_CreateInput(t *testing.T) {
 				"cabType": "yellow",
 				"distanceMiles": 8,
 				"withPet": true,
-				"time_value": "2017-03-20T19:35"
+				"time_value": "2017-03-20T19:35",
+				"null_value": null
 			}]`)
 	h := test.NewHandler()
 	h.Holder = hldr.Holder