Hi Yupeng,
I managed to find some time to respond. See my answers inlined below.
Matthias
On Fri, Jan 3, 2025 at 11:48 AM Yuepeng Pan wrote:
> [...]
> Sorry for not expressing this part clearly earlier.
> IIUC, based on the Adaptive Scheduler state diagram [1],
> when a stop-with-savepoint oper
xuyang created FLINK-37106:
--
Summary: Consider extracting common methods in WindowJoinOperator
Key: FLINK-37106
URL: https://issues.apache.org/jira/browse/FLINK-37106
Project: Flink
Issue Type: Tech
Hi, all.
I'd like to start a vote on FLIP-500: Support Join Extension in DataStream
V2 API [1]. You can find the discussion on it here[2].
The vote will last for at least 72 hours unless there is objection or
insufficient votes.
Best regards,
Xu Huang
[1] https://cwiki.apache.org/confluence/x/y
Hi everyone,
We hope to include this FLIP in the 2.0 version, which has a feature freeze
date of January 20th. To allow enough time for code review, we plan to
start the vote today.
If you have any questions or concerns, please feel free to ask them in this
discussion thread. We will respond as s
Hi, all.
I'd like to start a vote on FLIP-501: Support Window Extension in
DataStream V2 API [1]. You can find the discussion on it here [2].
The vote will last for at least 72 hours unless there is objection or
insufficient votes.
Best regards,
Xu Huang
[1] https://cwiki.apache.org/confluence/
Wenkai Qi created FLINK-37105:
-
Summary: Shade Apache Calcite in Flink CDC
Key: FLINK-37105
URL: https://issues.apache.org/jira/browse/FLINK-37105
Project: Flink
Issue Type: Improvement
Wenkai Qi created FLINK-37104:
-
Summary: Code simplification and cleaning related to Flink CDC
YAML Transform
Key: FLINK-37104
URL: https://issues.apache.org/jira/browse/FLINK-37104
Project: Flink
zhuanshenbsj1 created FLINK-37103:
-
Summary: The argument lists of the method
FactoryUtil.createDynamicTableSink are inconsistent.
Key: FLINK-37103
URL: https://issues.apache.org/jira/browse/FLINK-37103
Hi, Maximilian, Thank you very much for your reply and suggestions.
That makes sense to me.
> Do you think we could condition the DefaultSlotAssigner based
> on whether the cluster is a session or an application cluster? We
> would use the new slot assignment for application clusters. We cou
