當(dāng)前位置：首頁(yè) > 编程资源 > 编程问答 >内容正文

编程问答

Flink DDL的java代碼中的DeserializationSchemaFactory與TableSourceFactory報錯解決方案記錄彙總

發(fā)布時(shí)間：2023/12/31 编程问答 42 豆豆

生活随笔收集整理的這篇文章主要介紹了 Flink DDL的java代碼中的DeserializationSchemaFactory與TableSourceFactory報錯解決方案記錄彙總小編覺得挺不錯(cuò)的,現(xiàn)在分享給大家,幫大家做個(gè)參考.

下面的刪除線表示不在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 the classpath.
②	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	無(wú)報(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> </dependency>

Reference:

[1]flink連接到外部系統(tǒng)Kafka Connector API 代碼報(bào)錯(cuò)問(wèn)題org.apache.flink.table.factories.DeserializationSchemaFactory

總結(jié)

以上是生活随笔為你收集整理的Flink DDL的java代碼中的DeserializationSchemaFactory與TableSourceFactory報錯解決方案記錄彙總的全部?jī)?nèi)容，希望文章能夠幫你解決所遇到的問(wèn)題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。

上一篇： IPv6地址配置方式 IPV6地址设置)
下一篇： Type TIMESTAMP(6) of