retract stream UDAF使用问题

[bulterman]

上游是upsert-kafka connector 创建的table, 使用UDAF时发现accumlator里的变量一直没被更新？如果使用kafka 
connector是正常更新的
（为了测试方便，table里只有同一个PK的数据）