Flink SQL regular join 如何设置状态过期

在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版权协议,转载请附上原文出处链接和本声明。