svn commit: r1810606 - in /pig/trunk: CHANGES.txt src/org/apache/pig/backend/hadoop/executionengine/tez/plan/optimizer/TezOperDependencyParallelismEstimator.java

[rohini]

Author: rohini
Date: Mon Oct  2 22:05:03 2017
New Revision: 1810606

URL: http://svn.apache.org/viewvc?rev=1810606&view=rev
Log:
PIG-5307: NPE in TezOperDependencyParallelismEstimator (rohini)

Modified:
    pig/trunk/CHANGES.txt
    
pig/trunk/src/org/apache/pig/backend/hadoop/executionengine/tez/plan/optimizer/TezOperDependencyParallelismEstimator.java

Modified: pig/trunk/CHANGES.txt
URL: 
http://svn.apache.org/viewvc/pig/trunk/CHANGES.txt?rev=1810606&r1=1810605&r2=1810606&view=diff
==============================================================================
--- pig/trunk/CHANGES.txt (original)
+++ pig/trunk/CHANGES.txt Mon Oct  2 22:05:03 2017
@@ -52,6 +52,8 @@ OPTIMIZATIONS
  
 BUG FIXES
 
+PIG-5307: NPE in TezOperDependencyParallelismEstimator (rohini)
+
 PIG-5272: BagToTuple output schema is incorrect (juen1jp via rohini)
 
 PIG-5271: StackOverflowError when compiling in Tez mode (with union and 
replicated join) (knoguchi)

Modified: 
pig/trunk/src/org/apache/pig/backend/hadoop/executionengine/tez/plan/optimizer/TezOperDependencyParallelismEstimator.java
URL: 
http://svn.apache.org/viewvc/pig/trunk/src/org/apache/pig/backend/hadoop/executionengine/tez/plan/optimizer/TezOperDependencyParallelismEstimator.java?rev=1810606&r1=1810605&r2=1810606&view=diff
==============================================================================
--- 
pig/trunk/src/org/apache/pig/backend/hadoop/executionengine/tez/plan/optimizer/TezOperDependencyParallelismEstimator.java
 (original)
+++ 
pig/trunk/src/org/apache/pig/backend/hadoop/executionengine/tez/plan/optimizer/TezOperDependencyParallelismEstimator.java
 Mon Oct  2 22:05:03 2017
@@ -217,7 +217,7 @@ public class TezOperDependencyParallelis
         public void visitFilter(POFilter fl) throws VisitorException {
             if (fl.getPlan().size()==1 && fl.getPlan().getRoots().get(0) 
instanceof ConstantExpression) {
                 ConstantExpression cons = 
(ConstantExpression)fl.getPlan().getRoots().get(0);
-                if (cons.getValue().equals(Boolean.TRUE)) {
+                if (Boolean.TRUE.equals(cons.getValue())) {
                     // skip all true condition
                     return;
                 }