Hi！ SQL 目前并不支持 stateful udf，你可能需要通过 data stream api 来完成这个需求，详见文档 https://ci.apache.org/projects/flink/flink-docs-release-1.13/zh/docs/dev/datastream/operators/process_function/
andrew <15021959...@163.com> 于2021年8月17日周二 下午7:04写道： > hi,你好: > 通过flinksql读kafka数据流，实现监控用户信息基于上一次状态值发生变更触发最新用户信息输出.
