xmarker commented on pull request #17465: URL: https://github.com/apache/flink/pull/17465#issuecomment-950160789
@fapaul I have debug KafkaSinkITCase on my computer , I found the failure cause was due to SinkWriter.timestamp() is a negative number, when kafka producer serialize the record throws a runtime exception, and then flink task failover repeatedly, now i have fixed it and run KafkaSinkITCase no problem anymore. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: issues-unsubscr...@flink.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
