环境
Ambari2.7
HDP：3.1.4.0
Flink：1.13.6
Hive：3.1.0
Java：1.8
问题分析
集成cdc过程中，经过反复测试发现存在类冲突的jar包是： flink-sql-connector-hive-3.1.2_2.11-1.13.6.jar的guava。具体jar包名称根据你的环境信息自行确认。网上的删除相关的guava-x.jar然后升级guava版本并放入/opt/flink-x/lib的办法别再试了，无效。
解决办法
考虑最小改动，我们仅替换Preconditions类即可，给它手动加入缺少的checkArgument(String,Object)方法
- 1、删除flink-sql-connector-hive-3.1.2_2.11-1.13.6.jar中的com.google.common.base.Preconditions.class
- 2、修改guava-28.0的源码，在Preconditions.java中增加
public static void checkArgument(String errorMessageTemplate, @Nullable Object p1) {
throw new IllegalArgumentException(lenientFormat(errorMessageTemplate, p1));
}
public static void checkArgument(
@Nullable String errorMessageTemplate,
Object @Nullable ... errorMessageArgs) {
throw new IllegalArgumentException(lenientFormat(errorMessageTemplate, errorMessageArgs));
}
如果mvn package失败也不要紧，我们只是要class文件，编译不失败就行。
3、把编译后的com.google.common.base.Preconditions.class 替换到flink-sql-connector-hive-3.1.2_2.11-1.13.6.jar中
4、替换的办法
解压：建一个空目录，把jar包放进去，使用jar xvf flink-sql-connector-hive-3.1.2_2.11-1.13.6.jar解压。解压后注意手动删这个jar包本身
压缩：进入上面的目录执行jar cvf flink-sql-connector-hive-3.1.2_2.11-1.13.6-update.jar .
