Yun Tang created FLINK-36965:
Summary: Enable to allow re-create the pod watch with many retries
on k8s cluster failure
Key: FLINK-36965
URL: https://issues.apache.org/jira/browse/FLINK-36965
Project: Fli
Yanquan Lv created FLINK-36964:
--
Summary: Fix potential exception when SchemaChange in parallel
with Paimon Sink.
Key: FLINK-36964
URL: https://issues.apache.org/jira/browse/FLINK-36964
Project: Flink
Hi, everyone,
The discussion has not received any responses for a while. If there are no
further comments this week, I will close the discussion and initiate the
vote next Monday.
Thank you all for your input!
Best regards,
Feng Jin
On Fri, Dec 20, 2024 at 10:38 AM Feng Jin wrote:
> Hi
> Zu
Yanfei Lei created FLINK-36961:
--
Summary: Wait ForSt state excutor shutdown when disposing
Key: FLINK-36961
URL: https://issues.apache.org/jira/browse/FLINK-36961
Project: Flink
Issue Type: Sub-
Shuai Xu created FLINK-36962:
Summary: push down non-deterministic filter after stream join to
source by mistake
Key: FLINK-36962
URL: https://issues.apache.org/jira/browse/FLINK-36962
Project: Flink
Zakelly Lan created FLINK-36963:
---
Summary: Wrong context maintain around `asyncProcessWithKey`
Key: FLINK-36963
URL: https://issues.apache.org/jira/browse/FLINK-36963
Project: Flink
Issue Type:
If I understand correctly you use purely SQL workloads for savepoint
creation. In short such case the initial version won't be much help.
In a more detailed version SQL operators are creating non-keyed/operator
state data which is going to be supported later on.
The first version supports user cod