jdk 17 下,flink-sql 无法连接 postgresql #2417
Unanswered
ilwyiworld
asked this question in
Q&A
Replies: 0 comments
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
-
PostgreSQL 版本:15
![1](https://private-user-images.githubusercontent.com/7789175/261949831-29faa648-95d3-4045-96af-94c9893ebc06.png?jwt=eyJhbGciOiJIUzI1NiIsInR5cCI6IkpXVCJ9.eyJpc3MiOiJnaXRodWIuY29tIiwiYXVkIjoicmF3LmdpdGh1YnVzZXJjb250ZW50LmNvbSIsImtleSI6ImtleTUiLCJleHAiOjE3Mzk1OTQ5NDMsIm5iZiI6MTczOTU5NDY0MywicGF0aCI6Ii83Nzg5MTc1LzI2MTk0OTgzMS0yOWZhYTY0OC05NWQzLTQwNDUtOTZhZi05NGM5ODkzZWJjMDYucG5nP1gtQW16LUFsZ29yaXRobT1BV1M0LUhNQUMtU0hBMjU2JlgtQW16LUNyZWRlbnRpYWw9QUtJQVZDT0RZTFNBNTNQUUs0WkElMkYyMDI1MDIxNSUyRnVzLWVhc3QtMSUyRnMzJTJGYXdzNF9yZXF1ZXN0JlgtQW16LURhdGU9MjAyNTAyMTVUMDQ0NDAzWiZYLUFtei1FeHBpcmVzPTMwMCZYLUFtei1TaWduYXR1cmU9OTU5N2FkNzU2ZDVkYzJhM2I5NTE4Y2MxNDI5MmQ2NGM3NzhhZGZiNTM1YTYzYTk5OTNlODUwNmY1YzllMmVlYiZYLUFtei1TaWduZWRIZWFkZXJzPWhvc3QifQ.VSRYZaq-zXtPtd77gv-K6FAzCOyfg0fW8-k58-Yr-Qc)
JDK 版本:17
Flink 版本:1.17
flink-sql-connector-postgres-cdc 版本:2.4
按照官网的例子创建 PG 连接后,无法查询表:
Flink1.17 不支持 jdk 17,所有我在 flink-conf.xml 中添加了相关配置后,Flink 能正常运行:
![3](https://private-user-images.githubusercontent.com/7789175/261950089-2e805258-b00e-4eb3-9c3f-e976713551f4.png?jwt=eyJhbGciOiJIUzI1NiIsInR5cCI6IkpXVCJ9.eyJpc3MiOiJnaXRodWIuY29tIiwiYXVkIjoicmF3LmdpdGh1YnVzZXJjb250ZW50LmNvbSIsImtleSI6ImtleTUiLCJleHAiOjE3Mzk1OTQ5NDMsIm5iZiI6MTczOTU5NDY0MywicGF0aCI6Ii83Nzg5MTc1LzI2MTk1MDA4OS0yZTgwNTI1OC1iMDBlLTRlYjMtOWMzZi1lOTc2NzEzNTUxZjQucG5nP1gtQW16LUFsZ29yaXRobT1BV1M0LUhNQUMtU0hBMjU2JlgtQW16LUNyZWRlbnRpYWw9QUtJQVZDT0RZTFNBNTNQUUs0WkElMkYyMDI1MDIxNSUyRnVzLWVhc3QtMSUyRnMzJTJGYXdzNF9yZXF1ZXN0JlgtQW16LURhdGU9MjAyNTAyMTVUMDQ0NDAzWiZYLUFtei1FeHBpcmVzPTMwMCZYLUFtei1TaWduYXR1cmU9MzgxZjNiYzY3NmU4M2EyMDA1ODk5NWNkMTg5MjI3YWI0N2FkNGU4MjQxMmE0ZDZjNDk2N2RmNmJhOWFjODNlOSZYLUFtei1TaWduZWRIZWFkZXJzPWhvc3QifQ.cB2mYBNMdLsBuNHWKqYhqIs7gfzv3_pEZIyI4r9-PYg)
而且在 Flink-SQL 的启动日志里面也看到了相关的配置信息:
![4](https://private-user-images.githubusercontent.com/7789175/261950495-f9159c0f-b503-4fc4-9e76-38b87ace3152.png?jwt=eyJhbGciOiJIUzI1NiIsInR5cCI6IkpXVCJ9.eyJpc3MiOiJnaXRodWIuY29tIiwiYXVkIjoicmF3LmdpdGh1YnVzZXJjb250ZW50LmNvbSIsImtleSI6ImtleTUiLCJleHAiOjE3Mzk1OTQ5NDMsIm5iZiI6MTczOTU5NDY0MywicGF0aCI6Ii83Nzg5MTc1LzI2MTk1MDQ5NS1mOTE1OWMwZi1iNTAzLTRmYzQtOWU3Ni0zOGI4N2FjZTMxNTIucG5nP1gtQW16LUFsZ29yaXRobT1BV1M0LUhNQUMtU0hBMjU2JlgtQW16LUNyZWRlbnRpYWw9QUtJQVZDT0RZTFNBNTNQUUs0WkElMkYyMDI1MDIxNSUyRnVzLWVhc3QtMSUyRnMzJTJGYXdzNF9yZXF1ZXN0JlgtQW16LURhdGU9MjAyNTAyMTVUMDQ0NDAzWiZYLUFtei1FeHBpcmVzPTMwMCZYLUFtei1TaWduYXR1cmU9NjQ4NzRkY2NhOWM2MzU4NmIwMjNjNjI3MzQ2OTJhZDliMWRjNjE0N2Y5OTFiNjg2YTBkYTdhZjg1MjI4NzI5OSZYLUFtei1TaWduZWRIZWFkZXJzPWhvc3QifQ.O18O_KAsD1NsCY1K_x4SaQe_8870K9apEPKuuVEVDTg)
所以只是单纯的 jdk 版本不匹配吗,还说跟 postgresql 版本也有关系
Beta Was this translation helpful? Give feedback.
All reactions