编程知识 cdmana.com

Summary of error reporting solution records of deserializationschemafactory and tablesourcefactory in Java code of Flink DDL

The strikeout below indicates that it is not in pom.xml Appears in the

Otherwise, it's going to be pom.xml Appears in the .

  The situation pom.xml kafka Version settings The corresponding error is reported

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 No error reported

 

Finally bug free Dependency configuration for (kafka The version is set to 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 Connecting to external systems Kafka Connector API Code error problem org.apache.flink.table.factories.DeserializationSchemaFactory

版权声明
本文为[Applied Sciences]所创,转载请带上原文链接,感谢
https://cdmana.com/2020/12/20201224214810583g.html

Scroll to Top