我使用flink从kafka读取数据并将其转换为protobuf。我面临的问题是,当我运行java应用程序时,会出现以下错误。(TypeExtractor.java:1515)已经包含在类的层次结构中,在org.apache.flink.api.java.typeutils.TypeExtractor.analyzePojo(TypeExtractor.java:1515) at org.apache.flink.api.java.typeutils.TypeExtractor的org.
作为开始,我尝试了一个基本查询,但是由于强制转换异常,我无法执行它。:100)at org.apache.flink.streaming.runtime.tasks.SourceStreamTask:93)
at org.apache.flink.api.java.typeutils.runtime.RowSerializer.copy(R
但是,在为mvn install项目运行时,会出现以下错误:
org.apache.flink.table.api.ValidationException: Could not find any factoriesthat implement 'org.apache.flink.table.delegation.ExecutorFactory' in the classpath.at org.apache.flink.table.factories.FactoryUtil.discov