关于FLINK PYTHON UDF

Wed, 15 Apr 2020 00:17:10 -0700 

你好

       我在使用kafka produce数据后，在python中使用UDF做一个add function，但
是最后的sink文件里面没有任何数据，

如果不用UDF的话直接获取一个数据在最后的sink文件里面是有数据的如下所示，DEBUG
很久也不清楚是什么原因是否能帮忙分下

 

Kafka用的测试数据 {"a": "bbb", "b": 3, "c": 1}

 



 



 

 

测试结果

Kafka用的测试数据 {"a": "bbb", "b": 3, "c": 1}



 

 

 

st_env.from_path("source")\
    .select("b.cast(LONG) as b1, c.cast(LONG) as c1") \
    .select("add(b1,c1)") \ 无任何输出
    .insert_into("result_tab")

无任何输出



 

 

st_env.from_path("source")\
    .select("b.cast(LONG) as b1, c.cast(LONG) as c1") \
    .select("c1")\   #正常输出

    .insert_into("result_tab")

正确输出

回复