From 7b7f471a184faabf1bcf075dd3ad56316d2f6e7d Mon Sep 17 00:00:00 2001
From: Linh Vo <lvo@umbel.com>
Date: Tue, 18 Jul 2017 10:16:10 -0500
Subject: [PATCH] skip null field when ingest data

---
 handler.go      |  3 +++
 handler_test.go | 13 ++++++++++++-
 2 files changed, 15 insertions(+), 1 deletion(-)

diff --git a/handler.go b/handler.go
index 87712feb0..7ebd673f7 100644
--- a/handler.go
+++ b/handler.go
@@ -1694,6 +1694,9 @@ func (h *Handler) InputJSONDataParser(req map[string]interface{}, index *Index,
 		for _, action := range field.Actions {
 			frame := action.Frame
 			timestamp := timestampFrame[action.Frame]
+			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)
diff --git a/handler_test.go b/handler_test.go
index 0609c22db..f2bb02f63 100644
--- a/handler_test.go
+++ b/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