You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pig.apache.org by ro...@apache.org on 2017/10/02 22:05:03 UTC

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

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;
                 }