diff --git a/ql/src/java/org/apache/hadoop/hive/ql/io/HiveInputFormat.java b/ql/src/java/org/apache/hadoop/hive/ql/io/HiveInputFormat.java index 1cb9557..4995bdf 100755 --- a/ql/src/java/org/apache/hadoop/hive/ql/io/HiveInputFormat.java +++ b/ql/src/java/org/apache/hadoop/hive/ql/io/HiveInputFormat.java @@ -234,7 +234,9 @@ public void configure(JobConf job) { for (String format : formats) { // TODO: should we check isAssignableFrom? if (ifName.equals(format)) { - LOG.info("Using SerDe-based LLAP reader for " + ifName); + if (LOG.isInfoEnabled()) { + LOG.info("Using SerDe-based LLAP reader for " + ifName); + } isSupported = isSerdeBased = true; break; } @@ -242,8 +244,10 @@ public void configure(JobConf job) { } } if (!isSupported || !isVectorized) { - LOG.info("Not using llap for " + ifName + ": supported = " + if (LOG.isInfoEnabled()) { + LOG.info("Not using llap for " + ifName + ": supported = " + isSupported + ", vectorized = " + isVectorized); + } return inputFormat; } if (LOG.isDebugEnabled()) { @@ -253,21 +257,27 @@ public void configure(JobConf job) { @SuppressWarnings("unchecked") LlapIo llapIo = LlapProxy.getIo(); if (llapIo == null) { - LOG.info("Not using LLAP IO because it is not initialized"); + if (LOG.isInfoEnabled()) { + LOG.info("Not using LLAP IO because it is not initialized"); + } return inputFormat; } Deserializer serde = null; if (isSerdeBased) { if (part == null) { - LOG.info("Not using LLAP IO because there's no partition spec for SerDe-based IF"); + if (LOG.isInfoEnabled()) { + LOG.info("Not using LLAP IO because there's no partition spec for SerDe-based IF"); + } return inputFormat; } VectorPartitionDesc vpart = part.getVectorPartitionDesc(); if (vpart != null) { VectorMapOperatorReadType old = vpart.getVectorMapOperatorReadType(); if (old != VectorMapOperatorReadType.VECTORIZED_INPUT_FILE_FORMAT) { - LOG.info("Resetting VectorMapOperatorReadType from " + old + " for partition " + if (LOG.isInfoEnabled()) { + LOG.info("Resetting VectorMapOperatorReadType from " + old + " for partition " + part.getTableName() + " " + part.getPartSpec()); + } vpart.setVectorMapOperatorReadType( VectorMapOperatorReadType.VECTORIZED_INPUT_FILE_FORMAT); } @@ -344,7 +354,9 @@ public RecordReader getRecordReader(InputSplit split, JobConf job, boolean nonNative = false; PartitionDesc part = HiveFileFormatUtils.getPartitionDescFromPathRecursively( pathToPartitionInfo, hsplit.getPath(), null); - LOG.debug("Found spec for " + hsplit.getPath() + " " + part + " from " + pathToPartitionInfo); + if (LOG.isDebugEnabled()) { + LOG.debug("Found spec for " + hsplit.getPath() + " " + part + " from " + pathToPartitionInfo); + } if ((part != null) && (part.getTableDesc() != null)) { Utilities.copyTableJobPropertiesToConf(part.getTableDesc(), job);