在doris中创建了新的Routine Load,报错:no partition in this topic怎么办?

提问者:帅平 问题分类:大数据

今天新创建了一个Routine Load,结果发现Routine Load的状态是Paused,没有被正确的执行,最后查看报错信息如下:ErrorReason{code=errCode = 4, msg='Job failed to fetch all current partition with error errCode = 2, detailMessage = Failed to get all partitions of kafka topic: topic_csv. error: errCode = 2, detailMessage = failed to get kafka partition info: [no partition in this topic]'} 怎么办?

1 个回答
你我这辈子最的依靠
你我这辈子最的依靠

这是由于在创建routineload的时候没有提前在kafka里面创建相关的topic,doris的routineload是不会自动在kafka里面创建topic的,因此这里可以进行如下方式解决:

1、在kafka里面创建对应的topic
2、把这个job再resume重置一下。

发布于:1个月前 (11-04)
我来回答