收件人: "User"
发送时间: 星期三, 2022年 6 月 08日 下午 3:19:19
主题: Re: Could not find a suitable table factory for
'org.apache.flink.table.planner.delegation.ParserFactory' in the classpath.
The following is part of the code ：
String createKafkaSql = "create table if not exists
the jar.
Best regards,
Yuxia
发件人: "顾斌杰"
收件人: "User"
发送时间: 星期三, 2022年 6 月 08日 下午 3:19:19
主题: Re: Could not find a suitable table factory for
'org.apache.flink.table.planner.delegation.ParserFactory' in the classpath.
The following is part of the code ：
.delegation.ParserFactory' in the classpath.
Reason: Required context properties mismatch. The following properties are
requested: table.sql-dialect=hive The following factories have been considered:
org.apache.flink.table.planner.delegation.DefaultParserFactory
at
org.apache.flink.client.program.PackagedProgram.callMainMethod(PackagedPro
etableFuture.java:1592)
... 7 more
Caused by: org.apache.flink.util.FlinkRuntimeException: Could not execute
application.
at
org.apache.flink.client.deployment.application.DetachedApplicationRunner.tryExecuteJobs(DetachedApplicationRunner.java:88)
at
org.apache.flink.client.deployment.application
va:114)
at
org.apache.flink.client.deployment.application.DetachedApplicationRunner.tryExecuteJobs(DetachedApplicationRunner.java:84)
... 10 more
Caused by: org.apache.flink.table.api.NoMatchingTableFactoryException: Could
not find a suitable table f
