diff --git ql/src/java/org/apache/hadoop/hive/ql/exec/vector/mapjoin/VectorMapJoinRowBytesContainer.java ql/src/java/org/apache/hadoop/hive/ql/exec/vector/mapjoin/VectorMapJoinRowBytesContainer.java index 32b60d0..d2e980c 100644 --- ql/src/java/org/apache/hadoop/hive/ql/exec/vector/mapjoin/VectorMapJoinRowBytesContainer.java +++ ql/src/java/org/apache/hadoop/hive/ql/exec/vector/mapjoin/VectorMapJoinRowBytesContainer.java @@ -305,9 +305,12 @@ public void clear() { } fileOutputStream = null; } - try { - FileUtil.fullyDelete(parentFile); - } catch (Throwable ignored) { + + if (parentFile != null) { + try { + FileUtil.fullyDelete(parentFile); + } catch (Throwable ignored) { + } } parentFile = null; tmpFile = null;