5分钟搞定Flink中SQL查询失败问题，告别错误提示！

2023-01-29 11:41:05

Flink SQL 查询疑难解答：解决“jdbc”工厂未找到错误

作为一名 Flink 工程师，在使用 SQL 查询功能时遇到问题是很常见的。其中一个常见的错误是：“Could not find any factory for identifier 'jdbc' that implements 'org.apache.flink.table.factories.DynamicTableFactory'”。

这个错误提示表明你尚未正确配置 JDBC 连接信息，导致无法访问外部数据源。别担心，解决这个问题非常简单，只需按照以下步骤操作即可：

检查兼容性

首先，确保 Flink 版本和 JDBC 驱动版本兼容：

Flink 1.12 及以上版本：JDBC 驱动版本 4.2 及以上
Flink 1.11 及以下版本：JDBC 驱动版本 4.1 及以下

添加 JDBC 驱动

使用 Maven 管理依赖时，将以下依赖项添加到 pom.xml 文件：

<dependency>
  <groupId>org.apache.flink</groupId>
  <artifactId>flink-connector-jdbc</artifactId>
  <version>1.13.2</version>
</dependency>

手动下载 JDBC 驱动时，将驱动 jar 包放在 Flink 的 classpath 中。

配置配置文件

在 Flink 的配置文件（flink-conf.yaml）中，添加以下配置：

taskmanager.network.memory.managed: true
table.exec.mini-batch.enabled: true
table.exec.mini-batch.allow-latency: 1s
table.optimizer.join-reorder.enabled: true
table.optimizer.agg-push-down-rewrite-enabled: true
table.optimizer.filter-push-down-rewrite-enabled: true
table.optimizer.join-push-down-rewrite-enabled: true
table.optimizer.prune-empty-rules-enabled: true
table.optimizer.sink-rewrite-enabled: true
table.optimizer.agg-phase-strategy: TWO_PHASE