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..b4673ab 100644 --- ql/src/java/org/apache/hadoop/hive/ql/exec/SMBMapJoinOperator.java +++ ql/src/java/org/apache/hadoop/hive/ql/exec/SMBMapJoinOperator.java @@ -160,7 +160,9 @@ public class SMBMapJoinOperator extends AbstractMapJoinOperator imp jobConf = this.getExecContext().getJc(); } forwardOp.initialize(jobConf, new ObjectInspector[] {fetchOp.getOutputObjectInspector()}); - l4j.info("fetchoperator for " + entry.getKey() + " initialized"); + if (l4j != null) { + l4j.info("fetchoperator for " + entry.getKey() + " initialized"); + } } }