Hi Jingsong, So i can write the code as following?
EnvironmentSettings settings = EnvironmentSettings.newInstance().useBlinkPlanner().inStreamingMode().build(); TableEnvironment tEnv = TableEnvironment.create(settings); tEnv.getConfig().getConfiguration().setString("state.backend","rocksdb");eEnv.sqlUpdate(......) Thanks, Lei wangl...@geekplus.com.cn From: Jingsong Li Date: 2020-03-12 11:32 To: wangl...@geekplus.com.cn CC: user Subject: Re: How to set stateBackEnd in flink sql program? Hi wanglei, If you are using Flink 1.10, you can set "state.backend=rocksdb" to "TableConfig.getConfiguration". And you can find related config options here[1]. [1] https://ci.apache.org/projects/flink/flink-docs-release-1.10/ops/config.html Jingsong Lee On Thu, Mar 12, 2020 at 11:15 AM wangl...@geekplus.com.cn <wangl...@geekplus.com.cn> wrote: EnvironmentSettings settings = EnvironmentSettings.newInstance().useBlinkPlanner().inStreamingMode().build(); TableEnvironment tEnv = TableEnvironment.create(settings); tEnv.sqlUpdate()... Is there a way i can set stateBackEnd like normal streaming program as folloing:StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment(); env.setStateBackend(new RocksDBStateBackend(args[0], true)); wangl...@geekplus.com.cn -- Best, Jingsong Lee