其中的包是Flink DataGen SQL连接器。

Question

其中Maven包是Flink DataGen SQL连接器

我经常在示例就像这个中找到带有导入语句的示例，但是在这个特定的例子中，搜索Maven或搜索引擎也没有给出结果。

下面是我得到的错误的图片：

​

pom.xml中的Flink包是：

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

我还试图包括：

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

但是它仍然不能解决导入和TableDescriptor.forConnector问题。

Answer 1

我不得不做一些调查，但我发现这些文档以一种与我所拥有的版本相同的方式工作：https://nightlies.apache.org/flink/flink-docs-release-1.13/docs/connectors/table/datagen/。

CREATE TEMPORARY TABLE GenOrders
WITH (
    'connector' = 'datagen',
    'number-of-rows' = '10'
)
LIKE ...

很抱歉，我没有提到Flink版本，但它是1.13。

Answer 2

DataGen连接器是内置的，不需要额外的依赖项.

看，这里