Re: Re: [DISCUSS] Early Fire Support for Flink SQL Interval Join

Hi Xingcan and Xuyang, Thanks so much for the feedback - it was very helpful! *> 1. The current output stream of a time interval outer join is an append-only stream. This change will make it a potential retractable stream. I'm not sure if the planner supports a dynamic output type like that. Coul

[jira] [Created] (FLINK-37082) Disable adaptive join optimization when enable batch job progress recovery

xingbe created FLINK-37082: -- Summary: Disable adaptive join optimization when enable batch job progress recovery Key: FLINK-37082 URL: https://issues.apache.org/jira/browse/FLINK-37082 Project: Flink

[jira] [Created] (FLINK-37081) The debezium version of sqlserver cdc needs to be upgraded to 2.6 or higher

zhang created FLINK-37081: - Summary: The debezium version of sqlserver cdc needs to be upgraded to 2.6 or higher Key: FLINK-37081 URL: https://issues.apache.org/jira/browse/FLINK-37081 Project: Flink

[jira] [Created] (FLINK-37080) Flink CDC Postgres when start with latest status in stream phase and add new table, it will be too slow

hql0312 created FLINK-37080: --- Summary: Flink CDC Postgres when start with latest status in stream phase and add new table, it will be too slow Key: FLINK-37080 URL: https://issues.apache.org/jira/browse/FLINK-37080

[jira] [Created] (FLINK-37079) ci fails at SqlYARNApplicationITCase.testDeployScriptViaSqlClient

xuyang created FLINK-37079: -- Summary: ci fails at SqlYARNApplicationITCase.testDeployScriptViaSqlClient Key: FLINK-37079 URL: https://issues.apache.org/jira/browse/FLINK-37079 Project: Flink Issue

[jira] [Created] (FLINK-37078) Update jackson-mapper-asl dependency

Anupam Aggarwal created FLINK-37078: --- Summary: Update jackson-mapper-asl dependency Key: FLINK-37078 URL: https://issues.apache.org/jira/browse/FLINK-37078 Project: Flink Issue Type: Bug

Re: Does Flink operator 1.1.0 support Flink 1.20?

flink kubernetes operator 1.10.0 already supports Flink 1.20 in FLINK-36129[1]. [1] https://issues.apache.org/jira/browse/FLINK-36129 Best, Rui On Wed, Jan 8, 2025 at 9:49 PM David Radley wrote: > Hi, > > We were looking at the documentation and wondered is there a statement > saying that the

[RESULT][VOTE] FLIP-493: Add K8S conditions to CRD's Status

Hi Everyone, I'm happy to announce that FLIP-493: Add K8S conditions to CRD's Status [1] has been accepted. The voting thread is here[2]. There were 6 votes, 3 of which are binding: David Radley Gyula Fóra (Binding) Maximilian Michels Rui Fan (Binding) Alexander Fedulov (Binding)

Re: [VOTE] FLIP-493: Add K8S conditions to CRD's Status

Hi Everyone, Thank you all for voting. I believe we have enough votes now. The results will be sent out in a separate email. Thanks Lajith On Thu, Jan 9, 2025 at 7:12 AM Yuepeng Pan wrote: > +1 (non-binding) > > > Best, > Yuepeng Pan > > > > > > > > > > > > At 2025-01-08 23:15:11, "Alexand

Re: [VOTE] FLIP-493: Add K8S conditions to CRD's Status

+1 (non-binding) Best, Yuepeng Pan At 2025-01-08 23:15:11, "Alexander Fedulov" wrote: >+1 (binding) >one thing I am missing in the FLIP/discussion thread is the cleanup >procedure/cap on the number of condition entries. Let's keep this in mind >for the review. > >Best, >Alex > >On Wed

Re: Memory leak in pekko's Netty 4 transport.

Hi, I spent some time on this issue and gathered my findings here [1]. ConradJam, if you have some time, can you mayve try to run your job with the following dynamic params added to `env.java.opts.taskmanager` in `config.yaml`: -Dorg.apache.flink.shaded.netty4.io.netty.tryReflectionSetAccessib

[DISCUSS] FLIP-502: QueryOperation SQL Serialization customization

Hi all, I'd like to start a discussion on adding a context to Operation and Expression SQL serialization stack to allow for serializing more expression that require custom handling, such as inline functions. Please see[1] for details. Looking forward to hearing from you. Best, Dawid [1] https://cw

Re: [VOTE] FLIP-493: Add K8S conditions to CRD's Status

+1 (binding) one thing I am missing in the FLIP/discussion thread is the cleanup procedure/cap on the number of condition entries. Let's keep this in mind for the review. Best, Alex On Wed, 8 Jan 2025 at 09:36, Rui Fan <1996fan...@gmail.com> wrote: > +1(binding) > > Best, > Rui > > On Wed, Jan 8

Does Flink operator 1.1.0 support Flink 1.20?

Hi, We were looking at the documentation and wondered is there a statement saying that the 1.10.0 Flink operator supports / has been verified with Flink 1.20? Kind regards, David. Unless otherwise st

[jira] [Created] (FLINK-37077) CLONE - Upgrade Stateful Functions to Flink 1.16.1

Oleksandr Kazimirov created FLINK-37077: --- Summary: CLONE - Upgrade Stateful Functions to Flink 1.16.1 Key: FLINK-37077 URL: https://issues.apache.org/jira/browse/FLINK-37077 Project: Flink

[jira] [Created] (FLINK-37076) Support PTF skeleton in planner

Timo Walther created FLINK-37076: Summary: Support PTF skeleton in planner Key: FLINK-37076 URL: https://issues.apache.org/jira/browse/FLINK-37076 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-37075) Cross-team verification for FLINK-31836

Xintong Song created FLINK-37075: Summary: Cross-team verification for FLINK-31836 Key: FLINK-37075 URL: https://issues.apache.org/jira/browse/FLINK-37075 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-37073) Cross-team verification for "Adaptive optimization for batch jobs"

Xintong Song created FLINK-37073: Summary: Cross-team verification for "Adaptive optimization for batch jobs" Key: FLINK-37073 URL: https://issues.apache.org/jira/browse/FLINK-37073 Project: Flink

[jira] [Created] (FLINK-37074) Cross-team verification for FLINK-31362

Xintong Song created FLINK-37074: Summary: Cross-team verification for FLINK-31362 Key: FLINK-37074 URL: https://issues.apache.org/jira/browse/FLINK-37074 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-37072) Cross-team verification for FLIP-472

Xintong Song created FLINK-37072: Summary: Cross-team verification for FLIP-472 Key: FLINK-37072 URL: https://issues.apache.org/jira/browse/FLINK-37072 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-37071) Cross-team verification for FLIP-398

Xintong Song created FLINK-37071: Summary: Cross-team verification for FLIP-398 Key: FLINK-37071 URL: https://issues.apache.org/jira/browse/FLINK-37071 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-37070) Cross-team verification for FLIP-461

Xintong Song created FLINK-37070: Summary: Cross-team verification for FLIP-461 Key: FLINK-37070 URL: https://issues.apache.org/jira/browse/FLINK-37070 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-37069) Cross-team verification for "Disaggregated State Management"

Xintong Song created FLINK-37069: Summary: Cross-team verification for "Disaggregated State Management" Key: FLINK-37069 URL: https://issues.apache.org/jira/browse/FLINK-37069 Project: Flink

[jira] [Created] (FLINK-37068) Cross-team verification for FLIP-473

Xintong Song created FLINK-37068: Summary: Cross-team verification for FLIP-473 Key: FLINK-37068 URL: https://issues.apache.org/jira/browse/FLINK-37068 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-37067) Cross-team verification for “Introduce DataStream API V2”

Xintong Song created FLINK-37067: Summary: Cross-team verification for “Introduce DataStream API V2” Key: FLINK-37067 URL: https://issues.apache.org/jira/browse/FLINK-37067 Project: Flink Iss

[jira] [Created] (FLINK-37066) Add Pre-check for Definition Query During Creation or Query Modification of Materialized Table

Feng Jin created FLINK-37066: Summary: Add Pre-check for Definition Query During Creation or Query Modification of Materialized Table Key: FLINK-37066 URL: https://issues.apache.org/jira/browse/FLINK-37066

[jira] [Created] (FLINK-37065) MySQL cdc can lose/skip data during recovering from the checkpoint

Ihor Mielientiev created FLINK-37065: Summary: MySQL cdc can lose/skip data during recovering from the checkpoint Key: FLINK-37065 URL: https://issues.apache.org/jira/browse/FLINK-37065 Project: F

[jira] [Created] (FLINK-37064) Validate Schema Column Name Conflicts in Definition Query During Materialized Table Creation or Alter Query

Feng Jin created FLINK-37064: Summary: Validate Schema Column Name Conflicts in Definition Query During Materialized Table Creation or Alter Query Key: FLINK-37064 URL: https://issues.apache.org/jira/browse/FLINK-3706

[jira] [Created] (FLINK-37061) Cross-team verification for FLINK-32688

Xintong Song created FLINK-37061: Summary: Cross-team verification for FLINK-32688 Key: FLINK-37061 URL: https://issues.apache.org/jira/browse/FLINK-37061 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-37062) Cross-team verification for FLINK-36147

Xintong Song created FLINK-37062: Summary: Cross-team verification for FLINK-36147 Key: FLINK-37062 URL: https://issues.apache.org/jira/browse/FLINK-37062 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-37063) Cross-team verification for "Drop support for Java 8"

Xintong Song created FLINK-37063: Summary: Cross-team verification for "Drop support for Java 8" Key: FLINK-37063 URL: https://issues.apache.org/jira/browse/FLINK-37063 Project: Flink Issue T

[jira] [Created] (FLINK-37060) Cross-team verification for FLIP-398

Xintong Song created FLINK-37060: Summary: Cross-team verification for FLIP-398 Key: FLINK-37060 URL: https://issues.apache.org/jira/browse/FLINK-37060 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-37059) Cross-team verification for FLINK-4602

Xintong Song created FLINK-37059: Summary: Cross-team verification for FLINK-4602 Key: FLINK-37059 URL: https://issues.apache.org/jira/browse/FLINK-37059 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-37058) Cross-team verification for FLINK-35573

Xintong Song created FLINK-37058: Summary: Cross-team verification for FLINK-35573 Key: FLINK-37058 URL: https://issues.apache.org/jira/browse/FLINK-37058 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-37055) Cross-team verification for "Introduce a clean configuration layer"

Xintong Song created FLINK-37055: Summary: Cross-team verification for "Introduce a clean configuration layer" Key: FLINK-37055 URL: https://issues.apache.org/jira/browse/FLINK-37055 Project: Flink

[jira] [Created] (FLINK-37057) Cross-team verification for "Revisit all config option types and default values"

Xintong Song created FLINK-37057: Summary: Cross-team verification for "Revisit all config option types and default values" Key: FLINK-37057 URL: https://issues.apache.org/jira/browse/FLINK-37057 Proj

[jira] [Created] (FLINK-37056) Cross-team verification for FLINK-23620

Xintong Song created FLINK-37056: Summary: Cross-team verification for FLINK-23620 Key: FLINK-37056 URL: https://issues.apache.org/jira/browse/FLINK-37056 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-37049) Cross-team verification for "Remove all Scala APIs"

Xintong Song created FLINK-37049: Summary: Cross-team verification for "Remove all Scala APIs" Key: FLINK-37049 URL: https://issues.apache.org/jira/browse/FLINK-37049 Project: Flink Issue Typ

[jira] [Created] (FLINK-37054) Cross-team verification for FLINK-33750

Xintong Song created FLINK-37054: Summary: Cross-team verification for FLINK-33750 Key: FLINK-37054 URL: https://issues.apache.org/jira/browse/FLINK-37054 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-37053) Cross-team verification for FLINK-14068

Xintong Song created FLINK-37053: Summary: Cross-team verification for FLINK-14068 Key: FLINK-37053 URL: https://issues.apache.org/jira/browse/FLINK-37053 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-37052) Cross-team verification for FLINK-36245

Xintong Song created FLINK-37052: Summary: Cross-team verification for FLINK-36245 Key: FLINK-37052 URL: https://issues.apache.org/jira/browse/FLINK-37052 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-37051) Cross-team verification for FLINK-36369

Xintong Song created FLINK-37051: Summary: Cross-team verification for FLINK-36369 Key: FLINK-37051 URL: https://issues.apache.org/jira/browse/FLINK-37051 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-37050) Cross-team verification for "Remove Sink V1 API in 2.0"

Xintong Song created FLINK-37050: Summary: Cross-team verification for "Remove Sink V1 API in 2.0" Key: FLINK-37050 URL: https://issues.apache.org/jira/browse/FLINK-37050 Project: Flink Issue

[jira] [Created] (FLINK-37048) Cross-team verification for "Remove Deprecated methods/fields/classes in DataStream API"

Xintong Song created FLINK-37048: Summary: Cross-team verification for "Remove Deprecated methods/fields/classes in DataStream API" Key: FLINK-37048 URL: https://issues.apache.org/jira/browse/FLINK-37048

[jira] [Created] (FLINK-37047) Cross-team verification for "Remove DataSet API"

Xintong Song created FLINK-37047: Summary: Cross-team verification for "Remove DataSet API" Key: FLINK-37047 URL: https://issues.apache.org/jira/browse/FLINK-37047 Project: Flink Issue Type:

[SUMMARY] Flink 2.0 Release Sync 01/08/2025

Hi devs, Here's a summary of today's release sync. - *Feature Freeze* Date is extended to *Jan 20* (originally Jan 13) - For developers of work items (both breaking changes and features) listed on the wiki page [1]: - Please *fill in the Documentation column* - If the work

[jira] [Created] (FLINK-37046) OceanBase CDC Support for DDL event handling, converted to Debezium JSON format.

hzk created FLINK-37046: --- Summary: OceanBase CDC Support for DDL event handling, converted to Debezium JSON format. Key: FLINK-37046 URL: https://issues.apache.org/jira/browse/FLINK-37046 Project: Flink

[jira] [Created] (FLINK-37045) Expose state v2 creation APIs to datastream user

Zakelly Lan created FLINK-37045: --- Summary: Expose state v2 creation APIs to datastream user Key: FLINK-37045 URL: https://issues.apache.org/jira/browse/FLINK-37045 Project: Flink Issue Type: Su

Re: [VOTE] FLIP-493: Add K8S conditions to CRD's Status

+1(binding) Best, Rui On Wed, Jan 8, 2025 at 4:12 PM Maximilian Michels wrote: > +1 > > Thanks for working on adding support for Conditions! > > -Max > > On Sat, Dec 21, 2024 at 7:54 PM wrote: > > > > +1 (binding) > > > > The simplified approach makes complete sense! > > > > Gyula > > > > Sent

Re: [VOTE] FLIP-493: Add K8S conditions to CRD's Status

+1 Thanks for working on adding support for Conditions! -Max On Sat, Dec 21, 2024 at 7:54 PM wrote: > > +1 (binding) > > The simplified approach makes complete sense! > > Gyula > > Sent from my iPhone > > > On 20 Dec 2024, at 16:33, David Radley wrote: > > > >  > > > > +1 (non-binding) from m