Re: [VOTE] FLIP-505: Flink History Server Scability Improvements, Remote Data Store Fetch and Per Job Fetch

Thanks for the proposal! +1 (non-binding). Cheers, Weiqing On Fri, Jun 6, 2025 at 10:17 AM Matt Cuento wrote: > +1 (non-binding) > > Thanks for the proposal! > > Best, > Matt > > *Matt Cuento* > *p: (205) 306-8068* > *e: cuentom...@gmail.com * > *w: linkedin.com/in/mcuento

[RESULT][VOTE] FLIP-497: Early Fire Support for Flink SQL Interval Join

Hi All, The voting [1] on FLIP-497: Early Fire Support for Flink SQL Interval Join [2] has concluded with the following result: Approving votes: Jiangjie (Becket) Qin (binding) Venkata Krishnan (non-binding) Xingcan Cui (binding) Xuyang (binding) There were no disapproving votes, so I’m happy to

Re: [DISCUSS] State Schema Evolution for RowData

> And another question: Could you describe in which case we need > `migrateElement`? > > > Best, > Zakelly > > On Mon, Apr 28, 2025 at 2:49 AM Weiqing Yang > wrote: > > > Hi Zakelly, > > > > Thanks for your feedback. > > > > You're

Re: [DISCUSS] State Schema Evolution for RowData

ble/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/typeutils/RowDataSerializer.java#L335 > [3] > > https://github.com/apache/flink/blob/f8b3c4b9a8ce1c6a094fcc0f292faea4bad8806c/flink-runtime/src/main/java/org/apache/flink/runtime/state/StateSerializerProvider.java#L312 > &

[jira] [Created] (FLINK-37732) FLIP-527: State Schema Evolution for RowData

Weiqing Yang created FLINK-37732: Summary: FLIP-527: State Schema Evolution for RowData Key: FLINK-37732 URL: https://issues.apache.org/jira/browse/FLINK-37732 Project: Flink Issue Type: New

[DISCUSS] State Schema Evolution for RowData

Hi all, I’d like to initiate a discussion about enhancing state schema evolution support for RowData in Flink. *Motivation* Flink applications frequently need to evolve their state schema as business requirements change. Currently, when users update a Table API or SQL job with schema changes inv

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

- INTERVAL '4' HOUR AND s.ship_time > GROUP BY o.window_start, o.window_end, buyer; > > What will be the behavior? Will both the aggregation and interval join? Or > will it only be applied to the join? > It would be useful to define the behavior here. > > Thanks, > >

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

nterval will > be ignored from this point on. > > That said, if the configuration proposed in this FLIP is intended not only > for join, but for general purpose early fire, then the interval config > makes sense. > > Thanks, > > Jiangjie (Becket) Qin > > On Mon, Jan

Re: [ANNOUNCE] New Apache Flink Committer - Xuyang

Congratulations, Xuyang! Best, Weiqing On Thu, Feb 20, 2025 at 2:15 AM Feng Jin wrote: > Congratulations, Xuyang! > > > Best, > Feng Jin > > On Thu, Feb 20, 2025 at 5:44 PM gongzhongqiang > wrote: > > > Congratulations, Xuyang! > > > > > > Best, > > Zhongqiang Gong > > > > Lincoln Lee 于2025年2

[VOTE] FLIP-497: Early Fire Support for Flink SQL Interval Join

Hi All, I'd like to start a vote on FLIP-497: Early Fire Support for Flink SQL Interval Join [1]. The discussion thread can be found here [2]. The vote will remain open for at least 72 hours unless there are objections or insufficient votes. [1] https://cwiki.apache.org/confluence/display/FLINK/

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

rote: > > > > > Hi Weiqing, > > > > > > Thanks, that makes sense! Looks like I missed it. > > > > > > Regards > > > Venkata krishnan > > > > > > > > > On Tue, Jan 21, 2025 at 10:55 PM Weiqing Yang < > yangweiqing...@gm

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

ases where only one > early fire is required within a window or interval. Thoughts? > > Regards > Venkata krishnan > > > On Mon, Jan 20, 2025 at 9:11 PM Weiqing Yang > wrote: > > > Hi Venkata, > > > > Thanks for your feedback! > > > >

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

ime or > will it be a one time output emission and another output emitted at the end > of the interval? > 2. Are there plans to support *late fire *similar to the window > aggregations in later FLIPs? > > Regards > Venkata krishnan > > > On Wed, Jan 15, 2025 at 6:16 

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

ave no problem and +1 for this > feature. > > > > > -- > > Best！ > Xuyang > > > > > > 在 2025-01-15 12:33:16，"Weiqing Yang" 写道： > >Hi Xuyang, > > > >Thank you for your detailed feedback! I’ve updated the proposal doc

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

E, and the ModifyKind is INSERT. > > - Nevertheless, whether early firing is enabled or disabled, the > IntervalJoin should always require its input to keep > > ModifyKind with INSERT_ONLY and UpdateKind with NONE. > > > > > -- > > Best！ > Xuyang > > &

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

red results regularly? > >3. The time interval join operator itself is not quite efficient when the > >state becomes large. Will there be any extra overhead after introducing > >this feature? > > > >Thanks, > >Xingcan > > > >On Mon, Jan 6, 2025 at 4:11

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

rZo/edit?tab=t.0#heading=h.z7bl0h2hwkph> Thank you! Best, Weiqing On Sun, Dec 22, 2024 at 11:19 PM Weiqing Yang wrote: > Hi all, > > I’d like to initiate a discussion about introducing early fire support for > Flink SQL interval joins. > > *Motivation* > In many streaming

[jira] [Created] (FLINK-36953) FLIP-497: Early Fire Support for Flink SQL Interval Join

Weiqing Yang created FLINK-36953: Summary: FLIP-497: Early Fire Support for Flink SQL Interval Join Key: FLINK-36953 URL: https://issues.apache.org/jira/browse/FLINK-36953 Project: Flink

[DISCUSS] Early Fire Support for Flink SQL Interval Join

Hi all, I’d like to initiate a discussion about introducing early fire support for Flink SQL interval joins. *Motivation* In many streaming applications, particularly real-time analytics and monitoring systems, it is valuable to obtain partial results earlier rather than waiting for full join con

Re: [ANNOUNCE] New Flink PMC member: Yang Wang

Congratulations Yang! Best, Weiqing On Thu, May 5, 2022 at 4:18 AM Xintong Song wrote: > Hi all, > > I'm very happy to announce that Yang Wang has joined the Flink PMC! > > Yang has been consistently contributing to our community, by contributing > codes, participating in discussions, mentoring