Flink 1.10 table setIdleStateRetentionTime

Tue, 26 Jan 2021 19:40:01 -0800 


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 metadata。不太明白是什么原因产生这个？是由于maxTime 问题吗？

回复