--
张国强
电话：18347773978
邮箱：zgq25302...@126.com
感谢你的回复，不过我仍有个疑问，这里的ts是事件时间event time，如何能够按处理时间processing
time推移而不依赖后续输入消息来自动修改SUM值？
例如输入select查询后，这时进来了一条用户登录消息，后面就一直没有别的用户登录消息进来，这时看到的行为应该是统计登录人数为1，而过了30分钟后这个统计登录人数自动变为0.
Yuan,Youjun 于2019年12月12日周四 上午9:28写道：
> 首先通过一个自定义表函数(table
> function)，将每条输入的消息变成3条消息，假设输入消息的时间为ts，产出的三条消息时间分别为：(ts-1, 0), (t
flink目前支不支持动态修改窗口大小和类型呢？例如先是统计5分钟窗口，而后修改成统计10分钟窗口.
附上我写的flink程序，输入Jack，输出一直是
Jack,0
Jack,1
Jack,1
而不是过了30秒后自动变回 Jack,0 麻烦看下是哪里的问题？谢谢！
import org.apache.flink.api.common.functions.MapFunction;
import org.apache.flink.api.common.typeinfo.TypeInformation;
import org.apache.flink.api.java.tuple.Tuple2;
import org.apache.flink.api.java.tuple.Tuple3;
im
