EnvironmentSettings settings = EnvironmentSettings.newInstance().useBlinkPlanner().inStreamingMode().build(); tEnv.sqlUpdate()... Is there a way i can set stateBackEnd like normal streaming program as folloing: StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment(); |
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]. Jingsong Lee
Best, Jingsong Lee |
Hi Jingsong, So i can write the code as following? EnvironmentSettings settings = EnvironmentSettings.newInstance().useBlinkPlanner().inStreamingMode().build(); eEnv.sqlUpdate(......)
Thanks,
Lei
|
Yes, You should take a look to [1]. Others config you need too. Best, Jingsong Lee
Best, Jingsong Lee |
Free forum by Nabble | Edit this page |