Hello,麻烦问下,为啥算子链 默认合并之后,数据更新,算子对应的接收和发送记录数不更新,一直显示为0.
图片发送了看不到,请看附件
感谢,我已经解决了。
更换了jdk 版本,重新替换了插件包
RS 于2021年11月22日周一 下午1:44写道:
> 图片看不到的,尽量不要发图片,你可以复制文字出来并说明下,
>
>
>
>
>
>
>
>
>
>
>
>
>
>
>
>
> 在 2021-11-22 13:14:13,"zhiyuan su" 写道:
>
> 我使用的是上面的jar 包。从1.13的文档处获取的,但维标注flink 版本,我理解应该是flink1.13版
感觉你的场景是近实时累计统计,你可以参考下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
[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
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