In which package is Flink DataGen SQL Connector-CodePudding

In which Maven package is

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.

CodePudding user response：

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

Look here