diff --git a/src/main/java/org/msgpack/hadoop/hive/udf/GenericUDTFMessagePackArray.java b/src/main/java/org/msgpack/hadoop/hive/udf/GenericUDTFMessagePackArray.java index 92e54c6..c8a92fd 100644 --- a/src/main/java/org/msgpack/hadoop/hive/udf/GenericUDTFMessagePackArray.java +++ b/src/main/java/org/msgpack/hadoop/hive/udf/GenericUDTFMessagePackArray.java @@ -141,7 +141,7 @@ public void process(Object[] o) throws HiveException { for (int i = 0; i < numCols; ++i) { MessagePackObject obj = null; int index = indexes[i]; - if(array.size() > index && index > 0) { + if(array.size() > index && index >= 0) { obj = array.get(indexes[i]); } if(obj == null) {