diff --git ql/src/java/org/apache/hadoop/hive/ql/exec/SMBMapJoinOperator.java ql/src/java/org/apache/hadoop/hive/ql/exec/SMBMapJoinOperator.java index dc74532..77dc140 100644 --- ql/src/java/org/apache/hadoop/hive/ql/exec/SMBMapJoinOperator.java +++ ql/src/java/org/apache/hadoop/hive/ql/exec/SMBMapJoinOperator.java @@ -144,9 +144,7 @@ public class SMBMapJoinOperator extends AbstractMapJoinOperator imp FetchOperator fetchOp = new FetchOperator(entry.getValue(),jobClone); fetchOpJobConfMap.put(fetchOp, jobClone); fetchOperators.put(entry.getKey(), fetchOp); - if (l4j != null) { - l4j.info("fetchoperator for " + entry.getKey() + " created"); - } + l4j.info("fetchoperator for " + entry.getKey() + " created"); } for (Map.Entry entry : fetchOperators.entrySet()) {