diff --git a/ql/src/java/org/apache/hadoop/hive/ql/exec/persistence/PTFRowContainer.java b/ql/src/java/org/apache/hadoop/hive/ql/exec/persistence/PTFRowContainer.java index ca5f585f52..5f201cf9f3 100644 --- a/ql/src/java/org/apache/hadoop/hive/ql/exec/persistence/PTFRowContainer.java +++ b/ql/src/java/org/apache/hadoop/hive/ql/exec/persistence/PTFRowContainer.java @@ -112,7 +112,7 @@ public void addRow(Row t) throws HiveException { public Row first() throws HiveException { Row r = super.first(); - if ( blockInfos.size() > 0 ) { + if ( blockInfos!=null && blockInfos.size() > 0 ) { InputSplit[] inputSplits = getInputSplits(); FileSplit fS = null; BlockInfo bI = blockInfos.get(0);