 ...
分类：
其他好文 时间：
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
翻译来源- DataStream API Event Time 翻译来源- DataStream API Generating Watermarks 翻译来源- DataStream API Builtin Watermark Generators 概览 事件时间 原文Event Time。 在本节 ...
分类：
移动开发 时间：
2021-03-10 13:40:25
阅读次数：
0
0 简介 Yarn-per-job模式提交流程 总图 1 程序起点 2 创建 Yarn 客户端应用程序 2.1 程序入口 2.2 解析输入参数 2.3 选择创建哪种类型的客户端 2.4 获取有效配置 2.5 调用用户代码的 main 方法 2.6 调用执行环境的 execute 方法 ...
分类：
其他好文 时间：
2021-03-05 13:16:30
阅读次数：
0
简介： 快手基于 Flink 的持续优化与实践的介绍。 一、Flink 稳定性持续优化 第一部分是 Flink 稳定性的持续优化。该部分包括两个方面，第一个方面，主要介绍快手在 Flink Kafka Connector 方面做的一些高可用，是基于内部的双机房读或双机房写和一些容错的策略。第二部分关 ...
分类：
其他好文 时间：
2021-03-05 12:54:40
阅读次数：
0
近日，Hudi社区合并了 Flink 引擎的基础实现（HUDI-1327），这意味着 Hudi 开始支持 Flink 引擎。 当前 Flink 版本的 Hudi 只支持读取 Kafka 数据，sink到 COW 类型的 Hudi 表中，其他功能还在完善。 这里我们简要介绍下如何从 Kafka 读取数 ...
分类：
其他好文 时间：
2021-03-04 13:29:01
阅读次数：
0
1. MySQL下载 官网下载地址： https://downloads.mysql.com/archives/community/ 2. 将下载的软件上传至服务器，进行解压及安装前的环境部署 [root@templates ~]# cd /server/tools/ #< 软件包上传至/serve ...
分类：
数据库 时间：
2021-03-03 12:08:01
阅读次数：
0
Docker 环境部署的oracle #查询oracle 实例 docker ps -a #进入实例 docker exec -it 58aca4848691 /bin/bash #切换oracle用户 su - oracle #设置oracle 环境变量 export ORACLE_HOME=/u ...
分类：
数据库 时间：
2021-02-25 11:52:18
阅读次数：
0
