?????? flink1.10.1/1.11.1 ????sql ????group ?? ???????? ?????? ????????????

1.10?? ---- ??: "user-zh"

?????? flink1.10.1/1.11.1 ????sql ????group ?? ???????? ?????? ????????????

?? ?? RocksDB StateBackend ---- ??: "user-zh"

?????? flink1.10.1/1.11.1 ????sql ????group ?? ???????? ?????? ????????????

??ttl?? val settings = EnvironmentSettings.newInstance().inStreamingMode().build() val tableEnv = StreamTableEnvironment.create(bsEnv, settings) val tConfig = tableEnv.getConfig tConfig.setIdleStateRetentionTime(Time.minutes(1440), Time.minutes(1450)) 1)3??

?????? flink1.10.1/1.11.1 ????sql ????group ?? ???????? ?????? ????????????

FsStateBackend??5checkpoint??300ms ??1440minute??5 checkpoint shared group

?????? flink1.10.1/1.11.1 ????sql ????group ?? ???????? ?????? ????????????

1.11.0hdfscheckpoint??checkpoint3?? ?? day ?? id groupby 7watermark?? tConfig.setIdleStateRetentionTime(Time.minutes(1440),