diff --git ql/src/java/org/apache/hadoop/hive/ql/plan/ConditionalResolverSkewJoin.java ql/src/java/org/apache/hadoop/hive/ql/plan/ConditionalResolverSkewJoin.java index 43f7720..97f5b75 100644 --- ql/src/java/org/apache/hadoop/hive/ql/plan/ConditionalResolverSkewJoin.java +++ ql/src/java/org/apache/hadoop/hive/ql/plan/ConditionalResolverSkewJoin.java @@ -94,7 +94,7 @@ public class ConditionalResolverSkewJoin implements ConditionalResolver, Seriali Path dirPath = new Path(path); FileSystem inpFs = dirPath.getFileSystem(conf); FileStatus[] fstatus = inpFs.listStatus(dirPath); - if (fstatus != null && fstatus.length > 0) { + if ((fstatus != null) && (fstatus.length > 0)) { Task task = entry.getValue(); List> parentOps = task.getParentTasks(); if(parentOps!=null){