java - 如何 setRestartStrategy 使用 TableEnvironment？

Question

TableEnvironment tableEnv = TableEnvironment.create(
        EnvironmentSettings
                .newInstance()
                .build());
                
tableEnv
   .getConfig()
   .getConfiguration()
   .setString("parallelism.default", "3");

我习惯TableEnvironment了executeSql，怎么setRestartStrategy办？

标签： javaapache-flink

Answer 1

一个好的方法可能是将此配置放入flink-conf.yaml. 例如，

restart-strategy: fixed-delay
restart-strategy.fixed-delay.attempts: 3
restart-strategy.fixed-delay.delay: 10s

https://ci.apache.org/projects/flink/flink-docs-stable/docs/deployment/config/#fault-tolerance