I have been working with the 1.17 version of the Apache Flink operator and
have below questions.
As part of upgrading the application, is the application suspended, i.e. it
is checkpointed, prior to doing an upgrade? Is there a concept of a hot
update where I can update the application while it is
Hi,
Please send email to user-unsubscr...@flink.apache.org if you want to
unsubscribe the mail from user@flink.apache.org, and you can refer [1][2]
for more details.
Best,
Hang
[1]
https://flink.apache.org/zh/community/#%e9%82%ae%e4%bb%b6%e5%88%97%e8%a1%a8
[2] https://flink.apache.org/community.h
Hi, the plan seems correct. You can debug in StreamingJoinOperator#processLeft
and #processRight by writing an IT case to see what happened. Do these records
arrive the join operator out of order? If they are, maybe you can check the
order while these data are sent in source.
--
Best
We encountered similar problems in production, and we want to integrate
FLINK-24035 to solve them, but we don't know how to repeat the problem.
