Flink DDL的java代碼中的DeserializationSchemaFactory與TableSourceFactory報錯解決方案記錄彙總
下面的刪除線表示不在pom.xml中出現(xiàn)
否則就在pom.xml中出現(xiàn)。
| 情況 | pom.xml | kafka版本設(shè)置 | 對(duì)應(yīng)的報(bào)錯(cuò) |
| ① | flink-connector-kafka_2.12 flink-connector-kafka-0.11_2.12 flink-json | 0.11/universal | Caused by: org.apache.flink.table.api.NoMatchingTableFactoryException: Could not find a suitable table factory for 'org.apache.flink.table.factories.TableSourceFactory' in |
| ② | flink-connector-kafka_2.12 flink-connector-kafka-0.11_2.12 flink-json | universal | Caused by: org.apache.flink.table.api.NoMatchingTableFactoryException: Could not find a suitable table factory for 'org.apache.flink.table.factories.TableSourceFactory' in the classpath. |
| flink-connector-kafka_2.12 flink-connector-kafka-0.11_2.12 flink-json | 0.11 | Caused by: java.lang.NoSuchMethodError: org.apache.flink.table.utils.TableSchemaUtils.checkNoGeneratedColumns (Lorg/apache/flink/table/api/TableSchema;)Lorg/apache/flink/table/api/TableSchema; | |
| ③ | flink-connector-kafka-0.11_2.12 flink-json | 0.11 | Reason: No factory implements 'org.apache.flink.table.factories.DeserializationSchemaFactory'. |
| flink-connector-kafka-0.11_2.12 flink-json | universal | Caused by: org.apache.flink.table.api.NoMatchingTableFactoryException: Could not find a suitable table factory for 'org.apache.flink.table.factories.TableSourceFactory' in the classpath. | |
| ④ | flink-connector-kafka_2.12 flink-json | 0.11 | Caused by: org.apache.flink.table.api.NoMatchingTableFactoryException: Could not find a suitable table factory for 'org.apache.flink.table.factories.TableSourceFactory' in the classpath. |
| flink-connector-kafka_2.12 flink-json | universal | 無報(bào)錯(cuò) |
?
最終bug free的依賴配置(kafka版本設(shè)置爲(wèi)universal)
<dependency><groupId>org.apache.flink</groupId><artifactId>flink-connector-kafka_2.12</artifactId><version>1.12.0</version> </dependency><dependency><groupId>org.apache.flink</groupId><artifactId>flink-json</artifactId><version>1.12.0</version><!--<scope>test</scope>--> </dependency>Reference:
[1]flink連接到外部系統(tǒng)Kafka Connector API 代碼報(bào)錯(cuò)問題org.apache.flink.table.factories.DeserializationSchemaFactory
總結(jié)
以上是生活随笔為你收集整理的Flink DDL的java代碼中的DeserializationSchemaFactory與TableSourceFactory報錯解決方案記錄彙總的全部?jī)?nèi)容，希望文章能夠幫你解決所遇到的問題。
- 上一篇： IPv6地址配置方式 IPV6地址设置)
- 下一篇： Type TIMESTAMP(6) of