首页 > TAG信息列表 > Flink1.9
Flink1.9.0升级到Flink1.12.1问题汇总
业务场景： Flink消费Kafka数据写入Hbase 组件版本： CDH：6.3.0 Flink：1.12.1 Hbase:2.1.0-cdh6.3.0 问题1： java.lang.NoSuchMethodError:org.apache.commons.cli.Option.builder(Ljava/lang/string;) 问题原因： hadoop-common依赖中commons-cli版本过低，导致程序运行找不到最新版的方编译flink1.9.0 报flink-fs-hadoop-shaded找不到
编译flink1.9.0 报flink-fs-hadoop-shaded找不到 1.Flink 源码下载 git clone git@github.com:apache/flink.git 然后你可以切换到项目的不同分支，执行下面命令将代码切换到 release-1.9 分支： git checkout release-1.9 2.Flink 源码编译 mvn clean install -Dmaven.test.s在mac上Flink1.9.0源码编译（使用yhadoop2.6.0-cdh5.15.1）
源码编译安装flink 前置条件： JDK8 Maven3 （jdk 和 maven 请自行搜索，谢谢！） 通过下载Flink源码进行编译，不是使用直接下载二进制包 Flink GitHub 地址 在releases中找到自己需要的版本。我用的是1.9.0版本：1.9.0 tar -zxvf flink-release-1.9.0.tar.gz [-C 可以指定需要放置的目在centos7.2上Flink1.9.1源码编译（hadoop2.6.0-cdh5.15.1）
编译步骤参照官网：https://ci.apache.org/projects/flink/flink-docs-release-1.9/flinkDev/building.html 0.按照官网：In addition you need Maven 3 and a JDK (Java Development Kit). Flink requires at least Java 8 to build.配置好前置条件。 1.github获取flink 最Flink1.9 TableAPI如何选择执行计划
Flink1.9合并了Blink的代码，也就意味着我们在使用Table API 开发程序的时候，可以选在两种不同的执行计划。一种是原来的Flink的执行计划。一种是Blink的执行计划。截止到1.9的版本，虽然集成了Blink的执行计划，但是并不建议在生产中使用。Flink的执行计划，统称为OldPlanner// **********