官方地址：https://ci.apache.org/projects/flink/flink-docs-release-1.12/dev/datastream_execution_mode.html

1. Flink1.12 Release

Apache Flink 社区很荣幸地宣布 Flink 1.12.0 版本正式发布！近 300 位贡献者参与了 Flink 1.12.0 的开发，提交了超过 1000 多个修复或优化。这些修改极大地提高了 Flink 的可用性，并且简化（且统一）了 Flink 的整个 API 栈。其中一些比较重要的修改包括：

• 在 DataStream API 上添加了高效的批执行模式的支持，这是批处理和流处理实现真正统一的运行时的一个重要里程碑。

使用Hive构建数据仓库已经成为了比较普遍的一种解决方案。目前，一些比较常见的大数据处理引擎，都无一例外兼容Hive。Flink从1.9开始支持集成Hive，不过1.9版本为beta版，不推荐在生产环境中使用。在Flink1.10版本中，标志着对 Blink的整合宣告完成，对 Hive 的集成也达到了生产级别的要求。值得注意的是，不同版本的Flink对于Hive的集成有所差异，本文将以最新的Flink1.12版本为例，阐述Flink集成Hive的简单步骤，以下是全文，希望对你有所帮助。

1. API

移除掉 ExecutionConfig 中过期的方法

1. 使用Debezium之前mysql相关配置

1
2
3
4
5

server-id         = 223344 
log_bin           = mysql-bin 
binlog_format     = ROW 
binlog_row_image  = FULL 
expire_logs_days  = 10 

重启mysql

1. 版本说明

• Oracle版本：11.2.0.1.0
• Linux版本：Centos 7.3
• Oracle GoldenGate版本：122022_fbo_ggs_Linux_x64_shiphome
• Oracle GoldenGate for Big Data版本：12.3.2.1.0
• 官方文档地址：https://www.oracle.com/middleware/technologies/goldengate.html