?????????????? flink sql??????????????????????????????????????????????????????????????????????????????cdc????????cdc??????????????????????state?????????????????????????????????????????????????????? state?????????????????????????? val config: TableConfig = tabEnv.getConfig config.setIdleStateRetention(Duration.ofHours(1))
