Github user geetikagupta16 commented on a diff in the pull request:
https://github.com/apache/carbondata/pull/1650#discussion_r157195978
--- Diff:
integration/spark2/src/main/scala/org/apache/spark/sql/optimizer/CarbonFilters.scala
---
@@ -78,9 +78,17 @@ object CarbonFilters {
Some(new LessThanEqualToExpression(getCarbonExpression(name),
getCarbonLiteralExpression(name, value)))
case sources.In(name, values) =>
- Some(new InExpression(getCarbonExpression(name),
- new ListExpression(
- convertToJavaList(values.map(f =>
getCarbonLiteralExpression(name, f)).toList))))
+ if (values.length == 1 && values(0) == null) {
+ Some(new InExpression(getCarbonExpression(name),
+ new ListExpression(
--- End diff --
I have made the null check for IN expression in line no. 89
---