1.10??
----
??:
"user-zh"
??
?? RocksDB StateBackend
----
??:
"user-zh"
??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??
FsStateBackend??5checkpoint??300ms
??1440minute??5
checkpoint shared group
1.11.0hdfscheckpoint??checkpoint3??
?? day ?? id groupby
7watermark??
tConfig.setIdleStateRetentionTime(Time.minutes(1440),