Hello Yuan,
I don't override any default settings, docker-compose.yml:
> services:
> jobmanager:
> image: flink:1.15.1-java11
> ports:
> - "8081:8081"
> command: jobmanager
> environment:
> - |
> FLINK_PROPERTIES=
> jobmanager.rpc.address: jobmanager
版本:Flink1.13.3 、Hudi0.10.1、Hive3.1.2
lib:
-rw-r--r-- 1 root root 92313 Nov 12 2021 flink-csv-1.13.3.jar
-rw-r--r-- 1 root root 106535831 Nov 12 2021 flink-dist_2.12-1.13.3.jar
-rw-r--r-- 1 root root148127 Nov 12 2021 flink-json-1.13.3.jar
-rw-r--r-- 1 root root 43317025 Jun 13
TD
At 2022-08-12 10:31:35, "Summer" wrote:
>
>
>版本:1.13.3
>
>
>lib目录下:
>-rw-r--r-- 1 root root 7759243 Aug 12 10:12
>flink-connector-hive_2.12-1.13.3.jar
>-rw-r--r-- 1 root root 92313 Aug 12 10:12 flink-csv-1.13.3.jar
>-rw-r--r-- 1 root root 106535831 Aug 12 10:12
Hi,
1. lib下只需要一个flink-sql-connector-hive的包,不再需要flink-connector-hive和hive-exec
2. flink-sql-connector-hive包版本不对,需要和flink的1.13.3版本一致
先试试看,不行的话,就是代码的问题了。
Thanks
At 2022-08-12 10:31:35, "Summer" wrote:
>
>
>版本:1.13.3
>
>
>lib目录下:
>-rw-r--r-- 1 root root 7759243 Aug 12 10:12