一、系统架构 1. 接入层 Canal、Flume、Kafka 针对业务系统数据，Canal监控Binlog日志，发送至kafka； 针对日志数...

做Flink做了好几年，让我感触最深的是，虽然写了Flink代码好多年，但是要让我通俗易懂地将Flink的重要的核心概念串起来，我一时还真找不到...

由于考虑到项目后期需要用Flink对接Hive，所以这次项目升级需要将Flink版本由1.10升级到1.11，且保证项目能够平稳的运行。 有人可...

最近有个项目，需要读取hive表中的数据写到Hbase中，正好flink1.10版本刚出来，而且支持连接hive，那就他了。 哪想到这才是噩梦的...