Flink Table/SQL API中DDL建表WITH参数的疑问及文档查询
Flink Table/SQL DDL WITH子句参数问题解答
为什么FileSystem和Print连接器的参数写法不同?
你遇到的connector.type与connector的差异,是Flink版本迭代中参数规范统一导致的:
- 早期Flink版本(1.10及之前)采用
connector.type指定连接器类型,配套用connector.xxx格式的参数配置细节(比如你写的connector.path)。 - 从1.11版本开始,官方简化了参数命名,直接用
connector指定连接器类型。部分老连接器(比如FileSystem)为了兼容旧代码,保留了connector.type的写法;但像Print这类较新的连接器,只遵循新规范,所以用connector.type='print'会报错。
简单来说:FileSystem连接器兼容新老两种参数写法,而Print连接器只支持新的connector参数。
如何查询WITH子句支持的详细参数?
每个连接器的WITH参数都有专属的详细说明,你可以在Flink官方文档里找到:
- 找到文档中的「Connectors」板块,定位到具体的连接器(比如FileSystem Connector、Print Connector)。
- 每个连接器页面的「Configuration Options」部分,会列出所有支持的参数,包括参数名称、是否必填、取值范围、功能描述。
- 比如FileSystem连接器的参数包含
connector(或兼容的connector.type)、connector.path等;Print连接器的核心参数是connector='print',还有可选的print-identifier等辅助参数。
注意:一定要切换到你正在使用的Flink版本对应的文档,不同版本的参数可能存在差异。
内容的提问来源于stack exchange,提问作者EsMe
相关产品推荐
相关产品推荐

