GroupWindowAggregate doesn't support consuming update and delete changes

[casel.chen]

使用 flink sql 1.12.1时遇到三个问题：


1. GroupWindowAggregate doesn't support consuming update and delete changes which is produced by node TableSourceScan(table=[[default_catalog, default_database, mcsp_pay_log, ...

按时间窗口聚合不支持上游是canal-json格式的cdc表的情况么？我的业务表其实是一张日志表，怎样用flink sql将retract table转成append table?







2. flink sql写hbase要如何设置 TTL 过期时间？




3. flink sql写influxdb，https://www.alibabacloud.com/help/zh/faq-detail/155018.htm
如果有tag1, tag1value1, tag1value2, tag2, tag2value1, tag2value2 下面这样写不行吗?

create table stream_test_influxdb(

    `metric` varchar,

    `timestamp` BIGINT,

    `tag1` varchar,

    `tag1value1` Double,

    `tag1value1` Double,

    `tag2` varchar,

    `tag2value1` Double,

    `tag2value1` Double,

)with( ... )