[
https://issues.apache.org/jira/browse/FLINK-25562?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ziqiang.wang updated FLINK-25562:
---------------------------------
Description:
[https://repo.maven.apache.org/maven2/org/apache/flink/flink-sql-connector-hive-1.2.2_2.11/1.13.5/flink-sql-connector-hive-1.2.2_2.11-1.13.5.jar]
Flink jar flink-sql-connector-hive-1.2.2_2.11.jar are not compatible with Hive
1.1.0.
I cloned the source code of Flink and modified the version of Hive in the POM
file of Hive sql connector to 1.1.0. Then I repackaged Flink-SQL-connector-Hive
and put it online, so there was no version conflict problem.
Version conflicts occur in the Hive-exe package.
For conflicts details, see the following figure.
!image-2022-01-07-14-54-37-874.png!
I hope the official website can provided other packaged jar for hive 1.1.x。
was:
[https://repo.maven.apache.org/maven2/org/apache/flink/flink-sql-connector-hive-1.2.2_2.11/1.13.5/flink-sql-connector-hive-1.2.2_2.11-1.13.5.jar]
目前flink 官网提供的用来连接hive 1.0.0 - 1.2.2 版本的jar包,其实是不兼容hive 1.1.0版本的。
我克隆flink的源码之后,修改了hive
connector里pom文件中hive的版本为1.1.0之后重新打包flink-sql-connector-hive,放到线上之后,才没有版本冲突问题。
版本冲突主要体现在hive-exe包。
具体报错可查看下图。
!image-2022-01-07-14-54-37-874.png!
希望官网能够对hive 1.1.x和hive 1.2.x分开打包,并将1.1.x版本的hive-sql连接器放到官网上。
> hive sql connector 依赖冲突
> -----------------------
>
> Key: FLINK-25562
> URL: https://issues.apache.org/jira/browse/FLINK-25562
> Project: Flink
> Issue Type: Improvement
> Components: Connectors / Hive
> Affects Versions: 1.13.3
> Environment: CDH:5.15.0
> hadoop:2.6.0
> hive:1.1.0
> flink:1.3.3
> Reporter: ziqiang.wang
> Priority: Minor
> Labels: easyfix
> Fix For: 1.13.3
>
> Attachments: image-2022-01-07-14-54-37-874.png
>
> Original Estimate: 12h
> Remaining Estimate: 12h
>
> [https://repo.maven.apache.org/maven2/org/apache/flink/flink-sql-connector-hive-1.2.2_2.11/1.13.5/flink-sql-connector-hive-1.2.2_2.11-1.13.5.jar]
> Flink jar flink-sql-connector-hive-1.2.2_2.11.jar are not compatible with
> Hive 1.1.0.
> I cloned the source code of Flink and modified the version of Hive in the POM
> file of Hive sql connector to 1.1.0. Then I repackaged
> Flink-SQL-connector-Hive and put it online, so there was no version conflict
> problem.
> Version conflicts occur in the Hive-exe package.
> For conflicts details, see the following figure.
> !image-2022-01-07-14-54-37-874.png!
> I hope the official website can provided other packaged jar for hive 1.1.x。
--
This message was sent by Atlassian Jira
(v8.20.1#820001)