0
点赞
收藏
分享

微信扫一扫

CentOS 7.x 安装Redis 6.2.13

萧让听雪 2023-07-25 阅读 39

报错内容

org.apache.flink.util.FlinkRuntimeException: Failed to send data to Kafka user_order_msg-1@-1 with FlinkKafkaInternalProducer{transactionalId='kafka-sink-97-1', inTransaction=true, closed=false} 
at org.apache.flink.connector.kafka.sink.KafkaWriter$WriterCallback.throwException(KafkaWriter.java:448)
at org.apache.flink.connector.kafka.sink.KafkaWriter$WriterCallback.lambda$onCompletion$0(KafkaWriter.java:429)
at org.apache.flink.streaming.runtime.tasks.StreamTaskActionExecutor$1.runThrowing(StreamTaskActionExecutor.java:50)
at org.apache.flink.streaming.runtime.tasks.mailbox.Mail.run(Mail.java:90)
at org.apache.flink.streaming.runtime.tasks.mailbox.MailboxProcessor.processMailsWhenDefaultActionUnavailable(MailboxProcessor.java:338)
at org.apache.flink.streaming.runtime.tasks.mailbox.MailboxProcessor.processMail(MailboxProcessor.java:324)
at org.apache.flink.streaming.runtime.tasks.mailbox.MailboxProcessor.runMailboxLoop(MailboxPr
举报

相关推荐

0 条评论