回复：Flink SQL的状态清理

2023-09-21 文章 faronzz
试试这个 t_env.get_config().set("table.exec.state.ttl", "86400 s") | | faronzz | | faro...@163.com | 回复的原邮件 | 发件人 | 小昌同学 | | 发送日期 | 2023年09月21日 17:06 | | 收件人 | user-zh | | 主题 | Flink SQL的状态清理 | 各位老师好，请教一下大家关于flink sql的状态清理问题，我百度的话只找到相关的minbath设置，sql是没有配置s

pyflink aggfunction in window tvf can not sink connection='kafka', it notice consuming update changesm, java aggfunction and aggfunction in flink, such as sum is ok

2023-08-26 文章 faronzz
TABLE(TUMBLE(TABLE source, DESCRIPTOR(rowtime),INTERVAL '1' HOURS)) group by window_start, window_end, name """ sql_query = """ select name,sum_udf(`value`) as agg_data from TABLE(TUMBLE(TABLE source, DESCRIPTOR(rowtime),INTERVAL '1' HO