各位好,

我有一个需求是要维表关联mysql数据,再upsert写入mysql,就是个丰富字段的简单需求。
 
现在有两个问题:
1.为了实现upsert插入,我试下来必须使用groupby指定key,但是select内又有很多非聚合项,所以没办法在groupby后面加上所有那些非聚合项,否则通不过calcite
 validation。

2.现在遇到了一个问题,跑一段时间会抱full GC,我估计是因为groupby导致的状态不清理。
请问flink sql ddl能通过类似SET 语句来设定ttl吗,搜了官方文档只有提到table 
api里有setIdelStateRententionTime。

感谢各位的指教。

发自我的iPhone

回复