guys, question,
how do we know what library is required for what...
the above it is saying i dont have the right library, can't see the location being the problem.
as far as i can see either the major version matches 1.18 or 1.18.1, and the Scala version is 2.12 as per the main flink build.
i se some flink_sql_connector and flink_connector... is on support to go with the flink sql container and the other with the jobmanager/taskmanager ?
d
D. Draco O'Brien
07/21/2024, 12:43 PM
I am wondering if you need both flink_sql_connector and flink_connector or not.
D. Draco O'Brien
07/21/2024, 12:59 PM
It looks like you are on Flink 1.18.1 and your SQL statements reference Confluent Schema Registry usage with Avro. If that remains the case you do need to jars for Flink Kafka Connector & also for Flink SQL Avro Registry.
g
George Leonard
07/21/2024, 1:10 PM
i do believe i do have both ?
d
D. Draco O'Brien
07/22/2024, 5:48 AM
maybe you can try just the sql one?
g
George Leonard
07/22/2024, 5:56 AM
morning. for now binned the apache flink setup, reverted to the confluent one, the apache broke everything... will try another day,
need to first figure out which bit is responsible for which, how it fits together and how to pick/where to pick which jar to do what...
would be great if there was a page that said for this functionality this is the jar you need, pick version specific as per your system.