Hi， 1. 如果我没记错的话，mysql的写入应该就是replace的方式写入的，应该不需要group by来实现upsert写入吧，除非你想要的是聚合结果。 2. 这个看你用的是哪种方式，如果是table api，可以直接用你说的这种方式来设置；如果用的是sql-client，可以直接在配置文件里面配置。
xu yihan <[email protected]> 于2020年6月4日周四 下午6:07写道： > 各位好， > > 我有一个需求是要维表关联mysql数据，再upsert写入mysql，就是个丰富字段的简单需求。 > > 现在有两个问题： > 1.为了实现upsert插入，我试下来必须使用groupby指定key，但是select内又有很多非聚合项，所以没办法在groupby后面加上所有那些非聚合项，否则通不过calcite > validation。 > > 2.现在遇到了一个问题，跑一段时间会抱full GC，我估计是因为groupby导致的状态不清理。 > 请问flink sql ddl能通过类似SET 语句来设定ttl吗，搜了官方文档只有提到table > api里有setIdelStateRententionTime。 > > 感谢各位的指教。 > > 发自我的iPhone -- Best, Benchao Li
