Check rand()

apache · Oct 23, 2018 · 5b21078 · 5b21078
1 parent c58ef59
commit 5b21078
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/integration/spark2/src/main/scala/org/apache/spark/sql/optimizer/CarbonLateDecodeRule.scala b/integration/spark2/src/main/scala/org/apache/spark/sql/optimizer/CarbonLateDecodeRule.scala
@@ -782,7 +782,7 @@ class CarbonLateDecodeRule extends Rule[LogicalPlan] with PredicateHelper {
 
     val updateDtrFn = finalPlan transform {
       case p@Project(projectList: Seq[NamedExpression], cd) =>
-        if (cd.isInstanceOf[Filter] || cd.isInstanceOf[LogicalRelation]) {
+        if (cd.isInstanceOf[LogicalRelation]) {
           p.transformAllExpressions {
             case a@Alias(exp, _)
               if !exp.deterministic && !exp.isInstanceOf[CustomDeterministicExpression] =>
@@ -800,7 +800,7 @@ class CarbonLateDecodeRule extends Rule[LogicalPlan] with PredicateHelper {
           p
         }
       case f@Filter(condition: Expression, cd) =>
-        if (cd.isInstanceOf[Project] || cd.isInstanceOf[LogicalRelation]) {
+        if (cd.isInstanceOf[LogicalRelation]) {
           f.transformAllExpressions {
             case a@Alias(exp, _)
               if !exp.deterministic && !exp.isInstanceOf[CustomDeterministicExpression] =>