Default values broken when inserting via kinesis.

disney · Aug 12, 2023 · c02c773 · c02c773
1 parent 15b2303
commit c02c773
Showing 1 changed file with 0 additions and 1 deletion.
diff --git a/core/session.go b/core/session.go
@@ -578,7 +578,6 @@ func (s *Session) getDefaultValueForColumn(a *Attribute, row interface{}, ignore
 				var err error
 				var val interface{}
 				if val, err = shared.GetPath(source, row, ignoreSourcePath, useNerd); err == nil {
-					val = r.(map[string]interface{})[source]
 					rm[v.FieldName] = val
 					if v.FieldName == a.FieldName {
 						return fmt.Sprintf("%v", val)