diff --git ql/src/java/org/apache/hadoop/hive/ql/udf/ptf/MatchPath.java ql/src/java/org/apache/hadoop/hive/ql/udf/ptf/MatchPath.java index 03f434f..cc2b77b 100644 --- ql/src/java/org/apache/hadoop/hive/ql/udf/ptf/MatchPath.java +++ ql/src/java/org/apache/hadoop/hive/ql/udf/ptf/MatchPath.java @@ -495,7 +495,10 @@ protected SymbolFunctionResult match(Object row, PTFPartitionIterator pI rowResult = symbolFn.match(row, pItr); } - result.nextRow = pItr.getIndex() - 1; + result.nextRow = pItr.getIndex(); + if(pItr.hasNext()) { + result.nextRow -= 1; + } return result; }