看堆栈信息是内存不够，调大一些看看。我之前在读取hdfs上的一个获取地理位置的离线库，也是内存溢出，通过调整内存大小解决的。用的streamingapi开发的作业，1.12.5版本。
| |
allanqinjy
|
|
allanqi...@163.com
|
签名由网易邮箱大师定制
On 10/8/2022 21:00，RS wrote：
Hi，
版本：Flink-1.15.1
有个场景，从hdfs读文件再处理数据，batch mode，10个并发，使用Flink
SQL定义执行，source是connector=filesystem，format=raw，path=
Hi，
版本：Flink-1.15.1
有个场景，从hdfs读文件再处理数据，batch mode，10个并发，使用Flink
SQL定义执行，source是connector=filesystem，format=raw，path=
执行任务的时候，有时候能成功，有时候失败了然后就一直失败，重启集群好像可以解决问题，这种情况如何是什么原因导致的？
集群的off-heap都是默认配置，
taskmanager.memory.task.off-heap.size=0
taskmanager.memory.framework.off-heap.size=128MB
报错堆栈：
Hi,
报错如下：
[ERROR] Could not execute SQL statement. Reason:
org.apache.flink.table.api.ValidationException: Multiple factories for
identifier 'kafka' that implement
'org.apache.flink.table.factories.DynamicTableFactory' found in the classpath.
Ambiguous factory classes are:
org.apache.flink.
