感谢回复🙏
导入了flink-sql-connector-kafka_2.11-1.12.2.jar和flink-connector-kafka_2.11-1.12.2.jar,并且放到了site-packages/pyflink/lib目录下,还是一样的报错。
test_source_table_1这个kafka的表应该是创建成功了,是查询的问题吗?



--
Sent from: http://apache-flink.147419.n8.nabble.com/

回复