Flink??Flink SQL??set
| |
MOBIN
|
??
??2021??02??1?? 18:06?L<1039601...@qq.com> ??
,??1.12?? EnvironmentSettings settings =
EnvironmentSettings.newInstance().inStreamingMode().useBlinkPlanner()
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
,但是感觉没生效一样
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
都试过了,没有一个对的。
感觉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)
ction = MySQLSource.builder()
. . .
.debeziumProperties(debeziumProperties())
.build();
| |
MOBIN
|
|
18814118...@163.com
|
??
??2021??04??27?? 14:46<1764232...@qq.com> ??
hi all
??flink cdc??stre