【Flink】Flink exactly-once 报错 Timeout expired after 60000 milliseconds while awaiting InitProducerId

喜欢ヅ旅行 2022-09-05 04:21 362阅读 0赞

文章目录

  • 1.概述
  • 2.源码分析

在这里插入图片描述

1.概述

flink 开启了exactly-once,设置了transaction.id
然后flink一直不停重启,一直报错

org.apache.kafka.common.errors.TimeoutException: org.apache.kafka.common.errors.TimeoutException: Timeout expired after 60000milliseconds while awaiting InitProducerId

界面还有如下的debug问题
在这里插入图片描述
taskManager的日志中,只有这一个错误,其它

发表评论

表情:
评论列表 (有 0 条评论,362人围观)

还没有评论,来说两句吧...

相关阅读