Repository: hive Updated Branches: refs/heads/master 6c364c66c -> 68b66a64f
HIVE-19347: TestTriggersWorkloadManager tests are failing consistently (Matt McCline, reviewed by Sergey Shelukhin) Project: http://git-wip-us.apache.org/repos/asf/hive/repo Commit: http://git-wip-us.apache.org/repos/asf/hive/commit/68b66a64 Tree: http://git-wip-us.apache.org/repos/asf/hive/tree/68b66a64 Diff: http://git-wip-us.apache.org/repos/asf/hive/diff/68b66a64 Branch: refs/heads/master Commit: 68b66a64f0d9b0d587a7ce1e085a0e8e45253adb Parents: 6c364c6 Author: Matt McCline <[email protected]> Authored: Fri May 11 02:48:07 2018 -0500 Committer: Matt McCline <[email protected]> Committed: Fri May 11 02:48:07 2018 -0500 ---------------------------------------------------------------------- .../hadoop/hive/ql/io/HiveInputFormat.java | 27 ++++---------------- 1 file changed, 5 insertions(+), 22 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/hive/blob/68b66a64/ql/src/java/org/apache/hadoop/hive/ql/io/HiveInputFormat.java ---------------------------------------------------------------------- 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 655d10b..3d965c0 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 @@ -284,7 +284,11 @@ public class HiveInputFormat<K extends WritableComparable, V extends Writable> } return inputFormat; } - serde = findSerDeForLlapSerDeIf(conf, part); + try { + serde = part.getDeserializer(conf); + } catch (Exception e) { + throw new HiveException("Error creating SerDe for LLAP IO", e); + } } if (isSupported && isVectorized) { InputFormat<?, ?> wrappedIf = llapIo.getInputFormat(inputFormat, serde); @@ -319,27 +323,6 @@ public class HiveInputFormat<K extends WritableComparable, V extends Writable> return false; } - private static Deserializer findSerDeForLlapSerDeIf( - Configuration conf, PartitionDesc part) throws HiveException { - VectorPartitionDesc vpart = part.getVectorPartitionDesc(); - if (vpart != null) { - VectorMapOperatorReadType old = vpart.getVectorMapOperatorReadType(); - if (old != VectorMapOperatorReadType.VECTORIZED_INPUT_FILE_FORMAT) { - if (LOG.isInfoEnabled()) { - LOG.info("Resetting VectorMapOperatorReadType from " + old + " for partition " - + part.getTableName() + " " + part.getPartSpec()); - } - vpart.setVectorMapOperatorReadType( - VectorMapOperatorReadType.VECTORIZED_INPUT_FILE_FORMAT); - } - } - try { - return part.getDeserializer(conf); - } catch (Exception e) { - throw new HiveException("Error creating SerDe for LLAP IO", e); - } - } - public static void injectLlapCaches(InputFormat<WritableComparable, Writable> inputFormat, LlapIo<VectorizedRowBatch> llapIo) { LOG.info("Injecting LLAP caches into " + inputFormat.getClass().getCanonicalName());
