[FIXED] In which package is Flink DataGen SQL Connector

Issue

In which Maven package is Flink DataGen SQL Connector?

I often find examples href="https://nightlies.apache.org/flink/flink-docs-stable/docs/dev/table/common/" rel="nofollow noreferrer">like this one with an import statement but it's not specified anywhere in which package, in this particular case searching Maven or search engines didn't yield a result either.

Here is a picture of the error that I get:

Flink packages in pom.xml are:

flink-java
flink-streaming-java_${scala.binary.version}
flink-clients_${scala.binary.version}
flink-statebackend-rocksdb_2.11
flink-table-api-java
flink-sql-client_2.11
flink-test-utils_2.11

I also tried including:

flink-connector-base
flink-connector-jdbc_2.12
flink-connector-kafka-base_2.11

But it still can't resolve the import and TableDescriptor.forConnector.

Solution

The DataGen connector is built-in, no additional dependencies are required.

Look here

Answered By - Niko
Answer Checked By - Katrina (JavaFixing Volunteer)