t-producer-java-exception-outoforderseq
--Original Mail --
Sender:SmileSmile
Send Date:Fri Jun 4 23:24:06 2021
Recipients:Yun Gao
CC:user
Subject:Re:Re: open checkpoint, send message to kafka
OutOfOrderSequenceException
Hi,
after fail
Hi,
after failover still OutOfOrderSequenceException. when I close checkpoint,
kafka broker still return OutOfOrderSequenceException to me .
At 2021-06-04 17:52:22, "Yun Gao" wrote:
Hi,
Have you checked if the error during normal execution, or right after failover?
Best,
Y
Hi,
Have you checked if the error during normal execution, or right after failover?
Best,
Yun
--
From:SmileSmile
Send Time:2021 Jun. 4 (Fri.) 11:07
To:user
Subject:open checkpoint, send message to kafka OutOfOrderSequenceExceptio
Dear all:
flink version is 1.12.4,kafka version is 1.1.1。topology is very
simple ,source-->flatmap--->sink ,enable checkpoint,job will fail after a few
hours 。 the error message is
Caused by: org.apache.flink.streaming.connectors.kafka.FlinkKafkaException:
Failed to send data to Kaf