fix oss spark operator

Summary: The object mapping library (jackson) doesn't give default value when the key is missing from json.

Reviewed By: econti

Differential Revision: D15447137

fbshipit-source-id: f25b818b1f03941f7f393b694a92f0b6025845c3
This commit is contained in:
Kittipat Virochsiri
2019-05-21 22:57:47 -07:00
committed by Facebook Github Bot
parent b3415d8d59
commit 7d2669a5d2
@@ -43,7 +43,8 @@ object Helper {
val dt = sqlContext.sparkSession.catalog
.listColumns(tableName)
.collect
.filter(column => columnNames.contains(column.name))
// null check is required because jackson doesn't care about default values
.filter(column => columnNames != null && columnNames.contains(column.name))
.map(column => column.name -> column.dataType)
.toMap
assert(dt.size == columnNames.size)