我正在尝试使用Python读取来自Kafka和sink数据到flink Streamingapi的PostgreSQL的数据。我正在使用Flink版本1.19.1和PostgreSQL 14.13。这是我的代码

问题描述 投票:0回答:0
Traceback (most recent call last): File "/home/mhtuan/work/flink_kafka/./src/main.py", line 102, in <module> ds.add_sink(JdbcSink.sink( File "/home/mhtuan/work/flink-1.19.1/opt/python/pyflink.zip/pyflink/datastream/connectors/jdbc.py", line 60, in sink File "/home/mhtuan/work/flink-1.19.1/opt/python/py4j-0.10.9.7-src.zip/py4j/java_gateway.py", line 1322, in __call__ File "/home/mhtuan/work/flink-1.19.1/opt/python/pyflink.zip/pyflink/util/exceptions.py", line 146, in deco File "/home/mhtuan/work/flink-1.19.1/opt/python/py4j-0.10.9.7-src.zip/py4j/protocol.py", line 326, in get_return_value py4j.protocol.Py4JJavaError: An error occurred while calling o174.getDeclaredMethod. : java.lang.NoSuchMethodException: org.apache.flink.connector.jdbc.internal.JdbcOutputFormat.createRowJdbcStatementBuilder([I)

有人知道如何修复它吗?非常感谢!
    

您可以解决这个问题吗?我遇到了同样的错误,似乎没有版本不匹配
    

python postgresql apache-flink
最新问题
© www.soinside.com 2019 - 2024. All rights reserved.