我正在研究FLINK-28060问题。我认为该问题已经解决，并将作为已解决的问题包含在ApacheFlink1.15.1中。当我查看release note的ApacheFlink发布说明时，这个问题在1.15.1中仍然没有解决。但是jira问题已经解决，解决级别也已经修复。在版本1中。16该问题将被包括在内，但我想知道为什么该问题不包括在1.15.1或1.15.2中，而是包括在1.16中？该问题是否有特殊原因需要稍后更新？
我正在研究FLINK-28060问题。我认为该问题已经解决，并将作为已解决的问题包含在ApacheFlink1.15.1中。当我查看release note的ApacheFlink发布说明时，这个问题在1.15.1中仍然没有解决。但是jira问题已经解决，解决级别也已经修复。在版本1中。16该问题将被包括在内，但我想知道为什么该问题不包括在1.15.1或1.15.2中，而是包括在1.16中？该问题是否有特殊原因需要稍后更新？
1条答案
按热度按时间ttp71kqs1#
不，这个问题在Flink 1.15.1中没有解决。直到1.15.1发布后很久，才对Kafka进行了必要的修复。
FLINK-28060是由与Flink 1.15.0捆绑在一起的Kafka版本中引入Kafka的一个错误引起的。Kafka社区最近提供了Kafka客户端的必要修复程序，Flink社区认为在1.16.0完成之前有足够的时间彻底测试这个新的Kafka版本，因此将其包括在1.16.0中。
如果您使用的是Flink 1.15.x，并且受到这个bug的困扰，您可以通过从JAR中排除与Flink捆绑在一起的Kafka客户端的bug版本来解决这个问题，并针对较新的版本进行构建。（除非您运行的是纯SQL作业，而不是提交JAR文件，否则这应该是可行的。）