Hi I am trying to do checkpointing on S3 and creating the config but it is not working, The config is not getting change for the JOB.

s_env = StreamExecutionEnvironment.get_execution_environment()
conf.set_string('checkpointing.mode', "EXACTLY_ONCE")
conf.set_string('state.backend', "filesystem")
conf.set_string('state.checkpoints.dir', checkpoint_location)

environment_settings = EnvironmentSettings.new_instance()\
    .in_streaming_mode() \
     .with_configuration(conf) \
      .build()

t_env = TableEnvironment.create(environment_settings)

Even Tried.

t_env.get_config().set('checkpointing.mode', "EXACTLY_ONCE")
t_env.get_config().set('state.backend', "filesystem")
t_env.get_config().set('state.checkpoints.dir', checkpoint_location)