Re: [DISCUSS] FLIP-499: Support Event Time by Generalized Watermark in DataStream V2

Hello XU,Happy new year. Thank you for FLIP-499 and FLIP-467. I tried to split/chunk streams based by fixed timestamp intervals and route them to the appropriate destination. A few months ago, I evaluated the following options and found that Flink currently lacks direct support for a global wat

Re: Re:[DISSCUSS] Removing default error methods from the new public api stack in the table api when it implements both the new and deprecated public api stacks and the old stack is removed

Hi, Xuyang Thanks for initialized this proposal. +1 for remove the default implementation because 2.0 is breaking change, we don't need to keep api compatibility. Best, Ron Feng Jin 于2025年1月3日周五 13:36写道： > +1 Directly remove the default implementation, as this allows issues to be > detected at

Re: Re:[DISSCUSS] Removing default error methods from the new public api stack in the table api when it implements both the new and deprecated public api stacks and the old stack is removed

+1 Directly remove the default implementation, as this allows issues to be detected at compile time rather than at runtime. Even if we keep these methods, it doesn’t seem to make much sense. Best, Feng Jin On Fri, Jan 3, 2025 at 12:57 PM Xuyang wrote: > +1 to delete the overrided default meth

[DISCUSS] FLIP-499: Support Event Time by Generalized Watermark in DataStream V2

Hi Devs, Weijie Guo and I would like to initiate a discussion about FLIP-499: Support Event Time by Generalized Watermark in DataStream V2 [1]. Event time is a fundamental

Re:Re:[DISSCUSS] Removing default error methods from the new public api stack in the table api when it implements both the new and deprecated public api stacks and the old stack is removed

+1 to delete the overrided default methods that throw exceptions. -- Best！ Xuyang 在 2025-01-03 12:55:38，"Xuyang" 写道： The discuss will be open for at least 72 hours to collect dicisions. -- Best！ Xuyang At 2025-01-03 12:06:38, "Xuyang" wrote: >Hi, all. > >Feng Jing

Re:[DISSCUSS] Removing default error methods from the new public api stack in the table api when it implements both the new and deprecated public api stacks and the old stack is removed

The discuss will be open for at least 72 hours to collect dicisions.-- Best！ Xuyang At 2025-01-03 12:06:38, "Xuyang" wrote: >Hi, all. > >Feng Jing, Ron Liu and I are are currently working on removing deprecated >public APIs from the table module and have encountered an issue. > >Ta

[DISSCUSS] Removing default error methods from the new public api stack in the table api when it implements both the new and deprecated public api stacks and the old stack is removed

Hi, all. Feng Jing, Ron Liu and I are are currently working on removing deprecated public APIs from the table module and have encountered an issue. Take CatalogFactory as an example, the CatalogFactory class implements both the new api Factory and the deprecated api TableFactory. Within Cata

Extend Flink jdbc Trino supported types

Hey folks, I'm considering contributing toward the implementation of the complex types (map,array,etc) in the jdbc driver for trino. Is there much progress already in this area? I couldn't find a JIRA ticket for this. Kind regards Chris

Re: Log4j JSONTemplateLayout

I've opened a ticket and a PR. Ticket: https://issues.apache.org/jira/browse/FLINK-36997 PR: https://github.com/apache/flink/pull/25888 It should be easy to include in the Flink 2.0 release. If someone could help with review that would be great. Thanks, Ryan van Huuksloot Sr. Production Engineer

[DISCUSS] FLIP-498: AsyncTableFunction for async table function support

I'd like to start a discussion of FLIP-498: AsyncTableFunction for async table function support [1] This feature proposes exposing AsyncTableFunction as a proper user defined function. The type already exists for Lookup Joins, but isn't usable as other UDFs. This FLIP would bring it up to parity

[jira] [Created] (FLINK-36997) Add Log4j JSONTemplateLayout to Flink-Dist

Ryan van Huuksloot created FLINK-36997: -- Summary: Add Log4j JSONTemplateLayout to Flink-Dist Key: FLINK-36997 URL: https://issues.apache.org/jira/browse/FLINK-36997 Project: Flink Issue

Re: [DISCUSS] FLIP-495: Support AdaptiveScheduler record and query the rescale history

Thanks Yuepeng for your response. I added my comments to the individual paragraphs below: > Thank you very much for the reminding The proposal makes sense to me. > Additionally, I'd like to confirm whether each rescale cycle/event > requires a status field, such as FAILED, IGNORED, SUCCESS, PENDI

[jira] [Created] (FLINK-36996) The schema and namespace of MySQL pipeline connector metadata are reversed

Thorne created FLINK-36996: -- Summary: The schema and namespace of MySQL pipeline connector metadata are reversed Key: FLINK-36996 URL: https://issues.apache.org/jira/browse/FLINK-36996 Project: Flink

[jira] [Created] (FLINK-36995) Support REPLACE MATERIALIZED TABLE AS statement

Feng Jin created FLINK-36995: Summary: Support REPLACE MATERIALIZED TABLE AS statement Key: FLINK-36995 URL: https://issues.apache.org/jira/browse/FLINK-36995 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-36994) Support Alter Materialized Table As Query

Feng Jin created FLINK-36994: Summary: Support Alter Materialized Table As Query Key: FLINK-36994 URL: https://issues.apache.org/jira/browse/FLINK-36994 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-36993) FLIP-492: Support Query Modifications for Materialized Tables

Feng Jin created FLINK-36993: Summary: FLIP-492: Support Query Modifications for Materialized Tables Key: FLINK-36993 URL: https://issues.apache.org/jira/browse/FLINK-36993 Project: Flink Issue

[jira] [Created] (FLINK-36992) Migrate SplitAggregateRule

Jacky Lau created FLINK-36992: - Summary: Migrate SplitAggregateRule Key: FLINK-36992 URL: https://issues.apache.org/jira/browse/FLINK-36992 Project: Flink Issue Type: Sub-task Component

[jira] [Created] (FLINK-36991) NPE in BinarySegmentUtils

Adam Domański created FLINK-36991: - Summary: NPE in BinarySegmentUtils Key: FLINK-36991 URL: https://issues.apache.org/jira/browse/FLINK-36991 Project: Flink Issue Type: Bug Affects Versi