Hello，Leonard报的错误是Could not find a suitable table factory for
'org.apache.flink.table.factories.TableSinkFactory' in the classpath.
不过，根据你的提示，我下载了flink-connector-jdbc_2.11-1.11.0.jar，放到了/opt/flink-1.11.0/lib/，作业成功运行了！早上跑的第一个作业，也是类似原因，下载了hbase
connector就好了，感谢答疑问！
在 2020-07-10
Hello，Zach
>>> 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.
>>>
>>>
>>> Reason: Required context properties mismatch.
这个错误，一般是SQL 程序缺少了SQL
Hi，
看样子是kafka table source没有成功创建，也许你需要将
org.apache.flink
flink-sql-connector-kafka_2.11
${flink.version}
这个jar 放到 FLINK_HOME/lib 目录下
Congxian Qiu 于2020年7月10日周五 上午10:57写道：
> Hi
>
> 从异常看，可能是某个包没有引入导致的，和这个[1]比较像，可能你需要对比一下需要的是哪个包没有引入。
>
> PS 从栈那里看到是 csv
Hi
从异常看，可能是某个包没有引入导致的，和这个[1]比较像，可能你需要对比一下需要的是哪个包没有引入。
PS 从栈那里看到是 csv 相关的，可以优先考虑下 cvs 相关的包
```
The following factories have been considered:
org.apache.flink.table.sources.CsvBatchTableSourceFactory
org.apache.flink.table.sources.CsvAppendTableSourceFactory
日志贴全了的，这是从yarn ui贴的full log，用yarn logs命令也是这些log，太简短，看不出错误在哪。。。
我又提交了另外之前用flink1.10跑过的任务，现在用flink1.11跑，报了异常：
SLF4J: Class path contains multiple SLF4J bindings.
SLF4J: Found binding in
[jar:file:/opt/flink-1.11.0/lib/log4j-slf4j-impl-2.12.1.jar!/org/slf4j/impl/StaticLoggerBinder.class]
SLF4J:
Hi
这个看上去是提交到 Yarn 了，具体的原因需要看下 JM log 是啥原因。另外是否是日志没有贴全，这里只看到本地 log，其他的就只有小部分
jobmanager.err 的 log。
Best,
Congxian
Zhou Zach 于2020年7月9日周四 下午9:23写道：
> hi all，
> 原来用1.10使用per job模式，可以提交的作业，现在用1.11使用应用模式提交失败，看日志，也不清楚原因，
> yarn log：
> Log Type: jobmanager.err
>
>
> Log Upload Time: Thu Jul 09
hi all，
原来用1.10使用per job模式，可以提交的作业，现在用1.11使用应用模式提交失败，看日志，也不清楚原因，
yarn log：
Log Type: jobmanager.err
Log Upload Time: Thu Jul 09 21:02:48 +0800 2020
Log Length: 785
SLF4J: Class path contains multiple SLF4J bindings.
SLF4J: Found binding in
