Flink处理函数实战之五：CoProcessFunction(双流处理) 欢迎访问我的GitHub https://github.com/zq2599/blog_demos 内容：所有原创文章分类汇总及配套源码，涉及Java、Docker、Kubernetes、DevOPS等； 欢迎访问我的Git ...
分类：
其他好文 时间：
2021-04-28 12:02:58
阅读次数：
0
1. 搭建测试环境安装 1.1 下载并启动docker-compose容器 # 该 Docker Compose 中包含的容器有： # DataGen：数据生成器。容器启动后会自动开始生成用户行为数据，并发送到 Kafka 集群中。默认每秒生成 1000 条数据，持续生成约 3 小时。也可以更改 d ...
分类：
数据库 时间：
2021-04-28 11:43:18
阅读次数：
0
在开发Flink程序在本地模式调试时，需要用webUI， 首先需要导入依赖 <!-- flink运行时的webUI --> <dependency> <groupId>org.apache.flink</groupId> <artifactId>flink-runtime-web_2.11</art ...
分类：
Web程序 时间：
2021-04-24 11:56:23
阅读次数：
0
FlinkSQL 和常见的SQL一样，也分为 DDL,DML,DQL,DCL。
本文的主要内容是探讨如何利用FlinkAPI 对多行SQL语句进行校验。 ...
分类：
数据库 时间：
2021-04-21 12:07:34
阅读次数：
0
一、大数据框架三种语义???? 在分布式系统中，如kafka、spark、flink等构成系统的任何节点都是被定义为可以彼此独立失败的。比如在 Kafka 中，broker 可能会 crash，在 producer 推送数据至 topic 的过程中也可能会遇到网络问题。根据 producer 处理此 ...
分类：
其他好文 时间：
2021-04-09 13:27:18
阅读次数：
0
##程序和数据流 Flink程序的基本构建块是streams和transformations（注意，DataSet在内部也是一个stream）。一个stream可以看成一个中间结果，而一个transformations是以一个或多个stream作为输入的某种operation，该operation利 ...
分类：
其他好文 时间：
2021-04-08 13:28:24
阅读次数：
0
 ...
分类：
其他好文 时间：
2021-03-31 12:06:27
阅读次数：
0
最近flink job出现了背压的问题, 后果是导致了checkpoint的生成超时, 影响了flink job的运行. ...
分类：
其他好文 时间：
2021-03-30 12:44:32
阅读次数：
0
阿里云实时计算负责人 - 王峰（莫问）/ FFA_2020-Flink as a Unified Engine - Now and Next-V4 2020年Flink 基于Flink 的流批一体数仓 基于Flink流批一体数据湖架构 PyFlink Flink Native on K8S 双链路数 ...
分类：
其他好文 时间：
2021-03-16 11:59:14
阅读次数：
0
TopN的常见应用场景，最热商品购买量，最高人气作者的阅读量等等。 1. 用到的知识点 Flink创建kafka数据源； 基于 EventTime 处理，如何指定 Watermark； Flink中的Window，滚动（tumbling）窗口与滑动（sliding）窗口； State状态的使用； P ...
分类：
其他好文 时间：
2021-03-12 13:00:59
阅读次数：
0
