Yes, You should take a look to [1]. Others config you need too.
[1] https://ci.apache.org/projects/flink/flink-docs-release-1.10/ops/config.html Best, Jingsong Lee On Thu, Mar 12, 2020 at 12:26 PM [email protected] < [email protected]> wrote: > 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 > > ------------------------------ > [email protected] > > > *From:* Jingsong Li <[email protected]> > *Date:* 2020-03-12 11:32 > *To:* [email protected] > *CC:* user <[email protected]> > *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 [email protected] < > [email protected]> 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)); >> >> >> ------------------------------ >> [email protected] >> > > > -- > Best, Jingsong Lee > > -- Best, Jingsong Lee
