Hi
??????flink sql??????????????????????????????????????????
val config = tableConfig.getConfiguration()
config.setString("table.exec.mini-batch.enabled", "true")
config.setString("table.exec.mini-batch.allow-latency", "5s")
config.setString("table.exec.mini-batch.size", "20")
????????FsStateBackend????RocksDBStateBackend??????????????????????????????????????checkpoint????????????????????????
??????????????????????????????????????????checkpoint????????????????????????????????????????????????????????????????????