Apache Flink

软件主页
关注
Apache Flink 是高效和分布式的通用数据处理平台,是一个流批一体分析引擎。 Apache Flink 声明式的数据分析开源系统,结合了分布式 MapReduce 类平台的高效,灵活的编程...
加载中
1
回答
Flink Watermark在时间窗口下怎么理解它的功能

如果我使用的是滚动时间窗口,还有必要设置watermark吗,固定时长比如每隔30秒就切割一次数据流处理,即使它是乱序,不还是30秒切割一次吗。我理解wa...

2021/08/21 15:20
1
回答
Flink 源码编译失败了,咋整好呀?

Flink : Table : Uber ............................... SUCCESS [ 0.005 s] [INFO...

2021/03/31 22:09
1
回答
java: -source 1.5 中不支持 lambda 表达式 ??设置了是1.8,咋整还是 1.5呀?

D:\202011\code\4codesguigu\FlinkTutorial\src\main\java\com\atguigu\apitest\pr...

2021/03/27 13:11
1
回答
Flink Table & sql 写入hive不成功

flink 1.11.2版本,使用flink table从kafka获取数据然后写入Hive表中,发现flink table确实可以从kafka中拿到数据...

2020/09/27 17:51
8
回答
「十二年,再出发」感恩一路有你

2020年8月31日,开源中国12岁啦~ 从2008年到2020年,从最开始的开源社区、到代码托管平台码云、再到后来的专业软件服务平台众包,开源中国一步一...

2020/08/30 23:49
4
回答
写了一个flink kafka到mysql流程,启动一直报错

写了一个flink kafka到mysql流程,启动一直报错 "C:\Program Files\Java\jdk1.8.0_181\bin\java.e...

2020/09/01 19:10
1
回答
3
回答
win10下如何使用docker安装ZooKeeper、Flink、Kafka?

win10下如何使用docker安装ZooKeeper、Flink、Kafka? 各位前辈能给出一些win10安装ZooKeeper、Flink、Kafk...

2019/12/17 09:15
1
回答
Flink的TTL是否会对数据一致性造成影响?

Time-To-Live 是否会对 Flink 的 数据一致性 造成影响吗? 比如:程序因为某个原因 回放 到上个 checkpoint 的状态了,然后它...

2019/09/30 15:52
1
回答
flink 基于k8s 的高可用方案

@yiduwangkai 你好,想跟你请教个问题: 你好,我在k8s上搭建flink ha 的时候遇到了,其中一个job manager 日志如下报错: ...

2019/06/14 17:32
2
回答
关于腾讯云的上传操作

大数据小白,最近在写一个实时读取kafka的topic并实时同步到cos的一个功能,目前实现是先存到本地再每隔5分钟上传到cos,想问问各位大神知不知道c...

2019/04/08 20:13
2
回答
Timer定时任务,在集群cancel掉本地却还在运行?

编写了一个定时任务,用的是Scala语言的Timer,然后放在了flink集群运行,但每次cancel掉任务时,后台还是会运行,日志还是会输出,导致后台任...

2019/04/09 20:18

没有更多内容

加载失败,请刷新页面

没有更多内容

返回顶部
顶部
返回顶部
顶部