Flink Watermark在时间窗口下怎么理解它的功能
如果我使用的是滚动时间窗口，还有必要设置watermark吗，固定时长比如每隔30秒就切割一次数据流处理，即使它是乱序，不还是30秒切割一次吗。我理解wat…
Flink Table & sql 写入hive不成功
flink 1.11.2版本，使用flink table从kafka获取数据然后写入Hive表中，发现flink table确实可以从kafka中拿到数据，但是却写不进hive，没有报错，请…
win10下如何使用docker安装ZooKeeper、Flink、Kafka?
win10下如何使用docker安装ZooKeeper、Flink、Kafka? 各位前辈能给出一些win10安装ZooKeeper、Flink、Kafka的教程吗？…
flink 基于k8s 的高可用方案
@yiduwangkai 你好，想跟你请教个问题： 你好，我在k8s上搭建flink ha 的时候遇到了，其中一个job manager 日志如下报错： 我目前环境如下，单独搭建…
Flink的TTL是否会对数据一致性造成影响？
Time-To-Live 是否会对 Flink 的 数据一致性 造成影响吗？ 比如：程序因为某个原因 回放 到上个 checkpoint 的状态了，然后它的执行结果与没有 回放 …
- 共 1 页
- 1
