[jira] [Created] (FLINK-36965) Enable to allow re-create the pod watch with many retries on k8s cluster failure

2024-12-25 Thread Yun Tang (Jira)
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

[jira] [Created] (FLINK-36964) Fix potential exception when SchemaChange in parallel with Paimon Sink.

2024-12-25 Thread Yanquan Lv (Jira)
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

Re: [DISCUSS] FLIP-492: Support Query Modifications for Materialized Tables.

2024-12-25 Thread Feng Jin
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

[jira] [Created] (FLINK-36961) Wait ForSt state excutor shutdown when disposing

2024-12-25 Thread Yanfei Lei (Jira)
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-

[jira] [Created] (FLINK-36962) push down non-deterministic filter after stream join to source by mistake

2024-12-25 Thread Shuai Xu (Jira)
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

[jira] [Created] (FLINK-36963) Wrong context maintain around `asyncProcessWithKey`

2024-12-25 Thread Zakelly Lan (Jira)
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:

Re: [DISCUSS] FLIP-496: SQL connector for keyed state data

2024-12-25 Thread Gabor Somogyi
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