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????????????????????????????????????????????????????????????????????

回复