| |
xuanxufeng
发表于 2016-5-3 18:30:00
点评
是使用这个UDF进行查询时报错
16/05/03 20:13:03 WARN scheduler.TaskSetManager: Lost task 1.0 in stage 1.0 (TID 6, 10.255.255.182): java.lang.NullPointerException
at $line41.$read$$iwC$$iwC$$i.
请教大神,我自定义了一个UDF,
def strIndex(fullStr: String):Int = {fullStr.length() }
sqlContext.udf.register("strIndex", strIndex _)
执行报错
不知是什么原因?
| |
bioger_hit
发表于 2016-5-4 07:38:13
| |