在Flink SQL中,使用多流 regular join会造成状态越来越大, 有内存溢出的风险,那么如何设置状态过期呢?
可在代码中添加如下的配置:
//Flink 1.10
StreamTableEnvironment tenv = StreamTableEnvironment.create(env, environmentSettings);
tenv.getConfig().setIdleStateRetentionTime(Time.hours(24), Time.hours(25));
版权声明:本文为weixin_47298890原创文章,遵循CC 4.0 BY-SA版权协议,转载请附上原文出处链接和本声明。