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
