Re: Flink 1.10 table setIdleStateRetentionTime

抱歉..弄错了 On 1/27/2021 11:39，xuhaiLong wrote： hi, Flink 1.10.1 on yarn，测试发现，`tableEnv.getConfig.setIdleStateRetentionTime(Time.days(180), Time.days(181))` 修改为 `tableEnv.getConfig.setIdleStateRetentionTime(Time.days(30), Time.days(31))`。在savePoInt中恢复 job 启动正常，运行的时候 在webUI Exception 中有连接 kafk

Flink 1.10 table setIdleStateRetentionTime

hi, Flink 1.10.1 on yarn，测试发现，`tableEnv.getConfig.setIdleStateRetentionTime(Time.days(180), Time.days(181))` 修改为 `tableEnv.getConfig.setIdleStateRetentionTime(Time.days(30), Time.days(31))`。在savePoInt中恢复 job 启动正常，运行的时候 在webUI Exception 中有连接 kafka 异常，Timeout expired while fetching topic