您好，能否把解决的思路介绍一下？
祝好
在2020年12月18日 10:38，丁浩浩<18579099...@163.com> 写道：
问题我自己已经解决。
在 2020年12月17日，下午9:00，丁浩浩 <18579099...@163.com> 写道：
flink版本：1.11.1
udaf函数代码来自于阿里云官网文档
以下是代码
public class TestSql {
public static void main(String[] args) throws Exception {
Hi ??
??flink TableEnvironment.sqlUpdateupdate ??
??
bbTableEnv.sqlUpdate("update order_tb a, min_max_usertime_tb b set a.mark=-2 " +
" where a.mac=b.mac and extract(epoch from a.usertime)/7200 = b.user_2hour " +
" and a.usertime > b.min_usertime
Hi ??
??flink TableEnvironment.sqlUpdateupdate ??
??
bbTableEnv.sqlUpdate("update order_tb a, min_max_usertime_tb b set a.mark=-2 " +
" where a.mac=b.mac and extract(epoch from a.usertime)/7200 = b.user_2hour " +
" and a.usertime > b.min_usertime
请教个问题，代码一直报 java.lang.NullPointerException错误，但变量明明初始化了，却仍然有该错误，找不到原因，请诸位指教。谢谢。
错误如下：
2021-01-12 04:36:09,950 INFO org.apache.flink.runtime.taskmanager.Task
- Window(TumblingEventTimeWindows(6), EventTimeTrigger,
WashDataDetectionFunction) -> Map -> Map -> Sink: Unnamed
