diff --git ql/src/java/org/apache/hadoop/hive/ql/udf/generic/GenericUDTFInline.java ql/src/java/org/apache/hadoop/hive/ql/udf/generic/GenericUDTFInline.java index 2152d97..500ab3c 100644 --- ql/src/java/org/apache/hadoop/hive/ql/udf/generic/GenericUDTFInline.java +++ ql/src/java/org/apache/hadoop/hive/ql/udf/generic/GenericUDTFInline.java @@ -18,7 +18,7 @@ package org.apache.hadoop.hive.ql.udf.generic; -import java.util.ArrayList; +import java.util.List; import org.apache.hadoop.hive.ql.exec.Description; import org.apache.hadoop.hive.ql.exec.UDFArgumentException; @@ -57,8 +57,11 @@ public StructObjectInspector initialize(ObjectInspector[] ois) throws UDFArgumen @Override public void process(Object[] os) throws HiveException { - for (Object row : new ArrayList(li.getList(os[0]))) { - forward(row); + List list = li.getList(os[0]); + if (list != null) { + for (Object row : list) { + forward(row); + } } }