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