Fix null value query regression

Azure · May 22, 2019 · 8583898 · 8583898
1 parent aabdf1a
commit 8583898
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/src/main/scala/com/microsoft/azure/cosmosdb/spark/schema/FilterConverter.scala b/src/main/scala/com/microsoft/azure/cosmosdb/spark/schema/FilterConverter.scala
@@ -54,7 +54,7 @@ private [spark] object FilterConverter extends CosmosDBLoggingTrait {
         case In(field, values)                => s"""(c${createFieldIdentifier(field)} IN (${values.map(value => createValueClause(value)).mkString(",")}))"""
         case LessThan(field, value)           => s"""(c${createFieldIdentifier(field)} < ${createValueClause(value)})"""
         case LessThanOrEqual(field, value)    => s"""(c${createFieldIdentifier(field)} <= ${createValueClause(value)})"""
-        case IsNull(field)                    => s"""(c${createFieldIdentifier(field)} = null"""
+        case IsNull(field)                    => s"""(c${createFieldIdentifier(field)} = null)"""
         case IsNotNull(field)                 => s"""(c${createFieldIdentifier(field)} != null)"""
         case And(leftFilter, rightFilter)     => s"""(${createWhereClause(Array(leftFilter))} AND ${createWhereClause(Array(rightFilter))})"""
         case Or(leftFilter, rightFilter)      => s"""(${createWhereClause(Array(leftFilter))} OR ${createWhereClause(Array(rightFilter))})"""