kafka 2.3集群发生脑裂重启后，在flink重试机制作用下flink sql
1.15作业有正常恢复kafka消费（写入下游数据库，能够从数据库查询到最新写入数据），但没有提交flink消费kafka消息的offset，导致消息积压告警。请问这是flink
1.15已知的issue么？如果是的话 issue编号是多少？谢谢！
Hi Matthias,
I am facing a similar issue with the need to have state on 2 keyed input
streams, but the state can only be cleared with events occurring in a third
input stream.
Do you have maybe some examples how to utilize MultipleInputStreamOperator you
have mentioned?
Thanks and kind regards
Unsubscribe
Unsubscribe
Hello, I am currently using Flink version 1.15.2 and have encountered an issue
with the HDFS delegation token expiring after 7 days in a Kerberos scenario.
I have seen a new delegation token framework
(https://issues.apache.org/jira/browse/FLINK-21232) and I have merged the
code commits from 1
Unsubscribe
