我得到错误“error 2078:catched error from udf:com.hadoop.pig.splitrec[catched exception processing input row[1]]”。我确信输入字符串越界了，但我不确定是哪个记录（记录编号）导致了问题。
我正在尝试创建日志以显示导致问题的记录，但我不确定是否要调试以打印/记录错误记录。
输入如下所示：

**pxw01yin 12000099pgen pxw01yinffffffff pxw01yinimfguipy04301y301 jfk 00888jfk 008880001 pimf 0000n/actrc5/txn08/scr301/序列/tex021@

pxw01pin 12000099pgen PXW01PINFFFFFFF pxw01pinimfguiav04301p301每03615每036150001 pimf 0000n/actrck/txn08/scr301/seq/tex021@**
上面的行是两个记录，我已经测试了它们（使用limit），它们不会引起问题。我有超过150kb的输入数据。
我使用的脚本：

SPLT_REC1 = load  '/user/hduser/output/realdata/pig_out6/part-m-00000' as (tran_array:chararray);
   register /home/cloudera/workspace/SplitRec.jar;
   define SplitRec com.Hadoop.pig.SplitRec();
   SPLT_REC2 = foreach SPLT_REC1 generate SplitRec(tran_array);
   store SPLT_REC2 into '/user/hduser/output/realdata/pig_out7';

package com.Hadoop.pig;
import  java.io.IOException;

import  org.apache.pig.EvalFunc;
import  org.apache.pig.data.Tuple;
import  org.apache.pig.impl.util.WrappedIOException;

@SuppressWarnings("deprecation")
public class SplitRec extends EvalFunc<String> {
public String exec(Tuple input) throws IOException {
    if (input == null || input.size() == 0)
        return null;

    try {
        String Str1 = (String)input.get(0);
        String delim1 = "PIMF+";
        String[] tokens1 = Str1.split(delim1);

        String part3 = tokens1[0];
        String part4 = tokens1[1];
        int len1 = part4.length();
        String part5 = part4.substring(8,len1);

        String conCat1 = part3+":"+part5;
        return conCat1;
    }
    catch(Exception e) {
        throw WrappedIOException.wrap("Caught exception processing input row ", e);
    }

}