打出来的jar中是否包含了 相应的依赖呢?

aiden <18765295...@163.com> 于2021年11月17日周三 下午2:34写道:

> 补充下抛错异常
> Caused by: org.apache.flink.table.api.NoMatchingTableFactoryException:
> Could not find a suitable table factory for
> 'org.apache.flink.table.delegation.ExecutorFactory' in
> the classpath.
>
> Reason: No factory implements
> 'org.apache.flink.table.delegation.ExecutorFactory'.
>
> The following properties are requested:
> class-name=org.apache.flink.table.planner.delegation.BlinkExecutorFactory
> streaming-mode=true
>
> The following factories have been considered:
> org.apache.flink.streaming.connectors.kafka.KafkaTableSourceSinkFactory
> at
> org.apache.flink.table.factories.TableFactoryService.filterByFactoryClass(TableFactoryService.java:215)
>
> at
> org.apache.flink.table.factories.TableFactoryService.filter(TableFactoryService.java:176)
>
> at
> org.apache.flink.table.factories.TableFactoryService.findAllInternal(TableFactoryService.java:164)
>
> at
> org.apache.flink.table.factories.TableFactoryService.findAll(TableFactoryService.java:121)
>
> at
> org.apache.flink.table.factories.ComponentFactoryService.find(ComponentFactoryService.java:50)
>
> at
> org.apache.flink.table.api.bridge.java.internal.StreamTableEnvironmentImpl.lookupExecutor(StreamTableEnvironmentImpl.java:185)
>
> ... 97 more
> SLF4J: Class path contains multiple SLF4J bindings.
> SLF4J: Found binding in
> [jar:file:/opt/soft/flink-1.13.0/lib/log4j-slf4j-impl-2.12.1.jar!/org/slf4j/impl/StaticLoggerBinder.class]
>
> SLF4J: Found binding in
> [jar:file:/opt/cloudera/parcels/CDH-6.3.2-1.cdh6.3.2.p0.1605554/jars/slf4j-log4j12-1.7.25.jar!/org/slf4j/impl/StaticLoggerBinder.class]
>
> SLF4J: See http://www.slf4j.org/codes.html#multiple_bindings for an
> explanation.
> SLF4J: Actual binding is of type
> [org.apache.logging.slf4j.Log4jLoggerFactory]
>
> org.apache.flink.table.factories.TableSinkFactory
>
> pom部分文件
> <dependency>
>     <groupId>org.apache.flink</groupId>
>
> <artifactId>flink-table-planner-blink_${scala.binary.version}</artifactId>
>     <version>${flink.version}</version>
> </dependency>
> <dependency>
>     <groupId>org.apache.flink</groupId>
>
> <artifactId>flink-table-api-java-bridge_${scala.binary.version}</artifactId>
>     <version>${flink.version}</version>
> </dependency>
> <dependency>
>     <groupId>org.apache.flink</groupId>
>
> <artifactId>flink-table-api-scala-bridge_${scala.binary.version}</artifactId>
>     <version>${flink.version}</version>
>     <scope>provided</scope>
> </dependency>
>
>
>
> 您好
>       我将flink
> sql建表程序提交到k8s执行时抛出如下异常,网上提示需要引入flink-table-planner-blink等依赖,但实际pom文件中已经引入,请问这个该如何解决,附部分pom文件,flink版本为1.13。谢谢。
>

回复