你这代码贴的乱七八糟。。。 你需要再richjoinfunction里面设置valuestate的生命周期,他不随着窗口而销毁,窗口只会销毁自己设定的state,有空你可以看看window的源码,里面有清理state的逻辑
-- Sent from: http://apache-flink.147419.n8.nabble.com/
你这代码贴的乱七八糟。。。 你需要再richjoinfunction里面设置valuestate的生命周期,他不随着窗口而销毁,窗口只会销毁自己设定的state,有空你可以看看window的源码,里面有清理state的逻辑
-- Sent from: http://apache-flink.147419.n8.nabble.com/