?????? ??????????

Flink??Flink SQL??set | | MOBIN | ?? ??2021??02??1?? 18:06?L<1039601...@qq.com> ?? ,??1.12?? EnvironmentSettings settings = EnvironmentSettings.newInstance().inStreamingMode().useBlinkPlanner()

回复： flink自定义connector相关报错

Sorry， 工程下路径是没错的，是我发邮件时打错了，还可能是什么原因导致的呢？谢谢 src/main/resources/META-INF/services | | MOBIN | 签名由网易邮箱大师定制 在2021年06月2日 17:05，Leonard Xu 写道： 路径错了 在 2021年6月2日，17:02，MOBIN <18814118...@163.com> 写道： META-INF.services/org.apache.flink.table.factories.Factory => META-INF

flink自定义connector相关报错

，但是感觉没生效一样 Tabel-common依赖也已经引入了 谢谢 | | MOBIN | 签名由网易邮箱大师定制

回复：窗口函数使用的时间类型

其次可以参考下阿里的demo: https://help.aliyun.com/document_detail/62512.html?spm=a2c4g.11186623.6.827.49531b09XfgsU7 | | MOBIN | 签名由网易邮箱大师定制 在2021年06月1日 19:37，guoyb<861277...@qq.com> 写道： 好的，谢谢！ 我试试 ---原始邮件--- 发件人: "Shuo Cheng"

回复：窗口函数使用的时间类型

是不是报的类似下面的错？ Window aggregate can only be defined over a time attribute column, but TIMESTAMP(3) encountered | | MOBIN | 签名由网易邮箱大师定制 在2021年06月1日 19:00，guoyb<861277...@qq.com> 写道： tumble() 开窗，需要的事件时间到底需要什么时间类型？一直报时间不对 timestamp(3) datetime time 都试过了，没有一个对的。

回复： prometheus metric中如何设置label

感觉labe value过滤考虑的情况比较少 private static final Pattern UNALLOWED_CHAR_PATTERN = Pattern.compile("[^a-zA-Z0-9:]"); 只允许数字、字母及冒号，其实自定义label的场景下，带/的情况也有【比如文件路径】、带.的情况也有【主机IP】 | | MOBIN | 签名由网易邮箱大师定制 在2021年05月11日 15:04，Tony Wei 写道： Hi, 1、是否是这种方式增加label 是的，MetricGroup#addGroup(key, value)

??????flink cdc ????mysql binlog?????? streaming????????????????????reload????????????????????

ction = MySQLSource.builder() . . . .debeziumProperties(debeziumProperties()) .build(); | | MOBIN | | 18814118...@163.com | ?? ??2021??04??27?? 14:46<1764232...@qq.com> ?? hi all ??flink cdc??stre