这个异常一般是由于 UDF 的实现用了主类型（int），但是实际的字段值有 null 值。
你可以试试先做个 where 条件过滤，将 null 值过滤掉？
Best,
Jark
On Mon, 20 Jul 2020 at 15:28, godfrey he wrote:
> 看不到图片信息，换一个图床工具上传图片吧
>
> Luan Cooper 于2020年7月17日周五 下午4:11写道：
>
> > 附一个 Job Graph 信息，在 Cal 处挂了
> > [image: image.png]
> >
> > On Fri, Jul 17, 2020 at
看不到图片信息，换一个图床工具上传图片吧
Luan Cooper 于2020年7月17日周五 下午4:11写道：
> 附一个 Job Graph 信息，在 Cal 处挂了
> [image: image.png]
>
> On Fri, Jul 17, 2020 at 4:01 PM Luan Cooper wrote:
>
>> 实际有 20 左右个字段，用到的 UDF 有 COALESCE / CAST / JSON_PATH / TIMESTAMP 类
>> *是指 UDF 返回了 NULL 导致的吗？*
>>
>>
>> On Fri, Jul 17, 2020 at
附一个 Job Graph 信息，在 Cal 处挂了
[image: image.png]
On Fri, Jul 17, 2020 at 4:01 PM Luan Cooper wrote:
> 实际有 20 左右个字段，用到的 UDF 有 COALESCE / CAST / JSON_PATH / TIMESTAMP 类
> *是指 UDF 返回了 NULL 导致的吗？*
>
>
> On Fri, Jul 17, 2020 at 2:54 PM godfrey he wrote:
>
>> udf_xxx的逻辑是啥？
>>
>>
>> Luan Cooper
实际有 20 左右个字段，用到的 UDF 有 COALESCE / CAST / JSON_PATH / TIMESTAMP 类
*是指 UDF 返回了 NULL 导致的吗？*
On Fri, Jul 17, 2020 at 2:54 PM godfrey he wrote:
> udf_xxx的逻辑是啥？
>
>
> Luan Cooper 于2020年7月17日周五 下午2:40写道：
>
> > Hi
> >
> > 我有这么一个 SQL
> > INSERT INTO es
> > SELECT
> > a,
> > udf_xxx(b)
> > FROM
udf_xxx的逻辑是啥？
Luan Cooper 于2020年7月17日周五 下午2:40写道：
> Hi
>
> 我有这么一个 SQL
> INSERT INTO es
> SELECT
> a,
> udf_xxx(b)
> FROM mongo_oplog -- 自定义 TableFactory
>
> Job 提交后 fail 了，从 Job 提交到 Fail 只有一处来自非业务代码的 NPE 如下，没有任何业务代码 Exception，可以稳定重现
>
> LUE _UTF-16LE'v2'))) AS return_received_time]) (1/1)
>
Hi
我有这么一个 SQL
INSERT INTO es
SELECT
a,
udf_xxx(b)
FROM mongo_oplog -- 自定义 TableFactory
Job 提交后 fail 了，从 Job 提交到 Fail 只有一处来自非业务代码的 NPE 如下，没有任何业务代码 Exception，可以稳定重现
LUE _UTF-16LE'v2'))) AS return_received_time]) (1/1)
(bdf9b131f82a8ebc440165b82b89e570) switched from RUNNING to FAILED.
