flink web UI job overview 中的算子记录条数不更新

2021-11-29 文章 zhiyuan su
Hello,麻烦问下,为啥算子链 默认合并之后,数据更新,算子对应的接收和发送记录数不更新,一直显示为0. 图片发送了看不到,请看附件

Re: 回复:flink1.13.1 sql client connect hivecatalog 报错

2021-11-22 文章 zhiyuan su
感谢,我已经解决了。 更换了jdk 版本,重新替换了插件包 RS 于2021年11月22日周一 下午1:44写道: > 图片看不到的,尽量不要发图片,你可以复制文字出来并说明下, > > > > > > > > > > > > > > > > > 在 2021-11-22 13:14:13,"zhiyuan su" 写道: > > 我使用的是上面的jar 包。从1.13的文档处获取的,但维标注flink 版本,我理解应该是flink1.13版

Re: 如何实现event triggered window?

2021-11-22 文章 zhiyuan su
感觉你的场景是近实时累计统计,你可以参考下window TVF 看下是否满足 https://flink-learning.org.cn/article/detail/a8b0895d4271bf6b770927eea214612d?tab=SQL&page=1 具体在第2章第一节 Pinjie Huang 于2021年11月22日周一 下午3:52写道: > Hi friends, > > Flink 自带的window 有tumlbing sliding 和 session 但是似乎没有event triggerred。 > > 比如说 想知道过去1小时event A trigge

回复:flink1.13.1 sql client connect hivecatalog 报错

2021-11-21 文章 zhiyuan su
[image: image.png] 我使用的是上面的jar 包。从1.13的文档处获取的,但维标注flink 版本,我理解应该是flink1.13版本编译的。 [image: image.png] 这个是yaml文件,我直接在sql 客户端,通过DDL 的方式去编写的话,也是如下报错: > Caused by: java.util.ServiceConfigurationError: > org.apache.flink.table.factories.Factory: > org.apache.flink.table.module.hive.HiveModuleFactory not

flink1.13.1 sql client connect hivecatalog 报错

2021-11-21 文章 zhiyuan su
Hello, friends ! 我按照官方文档使用 sql client 去连接hive catalog 时出错。 我的hive version 2.3.6 Flink version 1.13.1 感觉官方介绍的bundled 方式添加jar 包,在flink/lib 下添加如下截图的包。然后重启集群,启动了sql-client ,连接报错如下,看报错感觉缺包,不知道缺什么包。第二种方式也尝试了下,一样的报错。似乎无法创建catalog [image: image.png] Yaml 文件: [image: image.png] Readin