一、产生问题背景 我们公司正在准备从cdh迁回社区版hadoop集群，启动flink任务的时候，还未运行就直接报错...[作者空间]
一、背景 1、出现异常 公司准备从CDH迁回社区版Hadoop集群，直接把Hadoop升级为比较新的3.30版本，...[作者空间]
1、HiveSource-xxxx.xxxx's parallelism (200) is higher than...[作者空间]
一、源码下载 1、github地址（选择对应的release版本） https://github.com/apac...[作者空间]
一、1.11.0版本及以前 以前的方式是先编译flink-shaded-hadoop这个包，将hadoop和hiv...[作者空间]
一、调研的三种模式： 1、Flink On Yarn （1）PerJob模式 一个任务一个集群 （2）Sessio...[作者空间]
MySQL CDC连接器允许从MySQL数据库读取快照数据和增量数据。本文档根据ververica官网翻译了如何设...[作者空间]
滚动日志的配置 flink日志的配置主要是将配置放在flink/conf下面才起作用下面是我的滚动日志的配置，能够...[作者空间]
mysql引入包的问题 将import com.mysql.jdbc.Connection 替换成 import ...[作者空间]
1. 消费kafka的调优 关于并行度消费kafka的并行度我们都知道source端保持跟kafka的分区一致，因...[作者空间]
偶然的“有空”的发现 用了flink半年多了，平常有使用checkpoint和savepoint，比较关注任务的c...[作者空间]
介绍flink在本地运行和on yarn运行时的日志配置。 很多现代框架都是用门面模式进行日志输出，例如使用Slf...[作者空间]
第一坑：使用Stream 转table api 中的fromDataStream的java和scala写法（需要引...[作者空间]
