Correcting subject -> Could not find any factory for identifier 'jdbc'
From: Ronak Beejawat (rbeejawa)
Sent: Tuesday, January 11, 2022 6:43 PM
To: '[email protected]' <[email protected]>; '[email protected]'
<[email protected]>; '[email protected]' <[email protected]>
Cc: 'Hang Ruan' <[email protected]>; Shrinath Shenoy K (sshenoyk)
<[email protected]>; Karthikeyan Muthusamy (karmuthu) <[email protected]>;
Krishna Singitam (ksingita) <[email protected]>; Arun Yadav (aruny)
<[email protected]>; Jayaprakash Kuravatti (jkuravat) <[email protected]>; Avi
Sanwal (asanwal) <[email protected]>
Subject: what is efficient way to write Left join in flink
Hi Team,
Getting below exception while using jdbc connector :
Caused by: org.apache.flink.table.api.ValidationException: Could not find any
factory for identifier 'jdbc' that implements
'org.apache.flink.table.factories.DynamicTableFactory' in the classpath.
Available factory identifiers are:
blackhole
datagen
filesystem
kafka
print
upsert-kafka
I have already added dependency for jdbc connector in pom.xml as mentioned
below:
<dependency>
<groupId>org.apache.flink</groupId>
<artifactId>flink-connector-jdbc_2.11</artifactId>
<version>1.14.2</version>
</dependency>
<dependency>
<groupId>mysql</groupId>
<artifactId>mysql-connector-java</artifactId>
<version>5.1.41</version>
</dependency>
Referred release doc link for the same
https://nightlies.apache.org/flink/flink-docs-release-1.14/docs/connectors/table/jdbc/
Please help me on this and provide the solution for it !!!
Thanks
Ronak Beejawat
