Re: [VOTE] FLIP-539: Support WITH Clause in CREATE FUNCTION Statement in Flink SQL

Hey Dawid, +1 (non-binding). Thanks for driving the effort, Gustavo On Fri, 1 Aug 2025 at 16:18, Dawid Wysakowicz wrote: > Hi everyone, > > I'd like to start a vote on FLIP-539: Support WITH Clause in CREATE > FUNCTION Statement in Flink SQL [1], which has been discussed in this > thread [2].

Re: [DISCUSS] FLIP-539: Support WITH Clause in CREATE FUNCTION Statement in Flink SQL

Hi Dawid, That's a useful addition, +1. Thanks for the FLIP and for driving this. Gustavo On Thu, 31 Jul 2025 at 17:43, Natea Eshetu Beshada wrote: > Hey Dawid, > > Looks like a solid idea to me to help enrich functions, I am +1 this > proposal. > > Thanks, > Natea > > On Tue, Jul 29, 2025 at

[jira] [Created] (FLINK-38073) Add documentation for the MultiJoin Operator

Gustavo de Morais created FLINK-38073: - Summary: Add documentation for the MultiJoin Operator Key: FLINK-38073 URL: https://issues.apache.org/jira/browse/FLINK-38073 Project: Flink Issue

[jira] [Created] (FLINK-38050) Flink UI has fixed dropdown width and truncates metric names

Gustavo de Morais created FLINK-38050: - Summary: Flink UI has fixed dropdown width and truncates metric names Key: FLINK-38050 URL: https://issues.apache.org/jira/browse/FLINK-38050 Project

Re: Invite to Slack

Hey Juliusz, Try out this link: https://join.slack.com/t/apache-flink/shared_invite/zt-37sy2ayrm-oUApLhv~BLWFtTjgOiTlQA Welcome to the community, Gustavo On Thu, 3 Jul 2025 at 09:45, Juliusz Nadbereżny wrote: > Can I have an invite to Slack? > > Best, Juliusz >

Re: Slack Invite !

Hey Sachin, Try out this link: https://join.slack.com/t/apache-flink/shared_invite/zt-37sy2ayrm-oUApLhv~BLWFtTjgOiTlQA Welcome to the community, Gustavo On Thu, 3 Jul 2025 at 12:08, Sachin wrote: > Dear members, > > It would be really of great help if someone can send a Flink Slack invite > to

[jira] [Created] (FLINK-38043) Support joining without join keys

Gustavo de Morais created FLINK-38043: - Summary: Support joining without join keys Key: FLINK-38043 URL: https://issues.apache.org/jira/browse/FLINK-38043 Project: Flink Issue Type: Sub

[jira] [Created] (FLINK-38037) Configure hashDistribution with commonJoinKey

Gustavo de Morais created FLINK-38037: - Summary: Configure hashDistribution with commonJoinKey Key: FLINK-38037 URL: https://issues.apache.org/jira/browse/FLINK-38037 Project: Flink

Re: Slack invitation

Hi Jure, I've generated this invitation link, take a look if it works https://join.slack.com/t/apache-flink/shared_invite/zt-37sy2ayrm-oUApLhv~BLWFtTjgOiTlQA . Kind regards, Gustavo On Fri 20. Jun 2025 at 15:32, Jure Prevc wrote: > Hey, > Slack invitation on https://flink.apache.org/what-is-fl

Re: [VOTE] FLIP-525: Model ML_PREDICT, ML_EVALUATE Implementation Design

+1(non-binding). Kind regards, Gustavo On Fri, 20 Jun 2025 at 08:13, Ron Liu wrote: > +1, make sense. > > Best, > Ron > > Hao Li 于2025年6月19日周四 13:22写道： > > > Hi all, > > > > As part of the discussion in AsyncTableFunction PR [1], it's suggested to > > change the config name from `table.exec.as

Re: [DISCUSS] FLIP-440: Annotation naming for PTFs

Hi Timo, +1 (non-binding) for option A. Thanks for trying to address feedback quickly. Kind regards, Gustavo de Morais On Thu, 19 Jun 2025 at 15:51, Timo Walther wrote: > Hi everyone, > > I'm currently polishing FLIP-440, I would like to apply some last minute > changes

[jira] [Created] (FLINK-37973) Use RightToLeftJoin Rule for MultiJoins

Gustavo de Morais created FLINK-37973: - Summary: Use RightToLeftJoin Rule for MultiJoins Key: FLINK-37973 URL: https://issues.apache.org/jira/browse/FLINK-37973 Project: Flink Issue Type

[jira] [Created] (FLINK-37970) Support PLAN_TEST_FORCE_OVERWRITE for .xml artifacts

Gustavo de Morais created FLINK-37970: - Summary: Support PLAN_TEST_FORCE_OVERWRITE for .xml artifacts Key: FLINK-37970 URL: https://issues.apache.org/jira/browse/FLINK-37970 Project: Flink

[jira] [Created] (FLINK-37966) Add Semantic, Restore, Rel and ExecPlan Tests

Gustavo de Morais created FLINK-37966: - Summary: Add Semantic, Restore, Rel and ExecPlan Tests Key: FLINK-37966 URL: https://issues.apache.org/jira/browse/FLINK-37966 Project: Flink

[jira] [Created] (FLINK-37965) Add StreamPhysicalMultiJoinRule and FlinkLogicalMultiJoin

Gustavo de Morais created FLINK-37965: - Summary: Add StreamPhysicalMultiJoinRule and FlinkLogicalMultiJoin Key: FLINK-37965 URL: https://issues.apache.org/jira/browse/FLINK-37965 Project: Flink

[jira] [Created] (FLINK-37962) Implement visitMultiJoin for RelTimeIndicatorConverter

Gustavo de Morais created FLINK-37962: - Summary: Implement visitMultiJoin for RelTimeIndicatorConverter Key: FLINK-37962 URL: https://issues.apache.org/jira/browse/FLINK-37962 Project: Flink

[jira] [Created] (FLINK-37945) Add StreamPhysicalMultiJoin to FlinkChangelogModeInferenceProgram

Gustavo de Morais created FLINK-37945: - Summary: Add StreamPhysicalMultiJoin to FlinkChangelogModeInferenceProgram Key: FLINK-37945 URL: https://issues.apache.org/jira/browse/FLINK-37945 Project

[jira] [Created] (FLINK-37936) Support hint based State-TTL for StreamingMultiJoinOperator

Gustavo de Morais created FLINK-37936: - Summary: Support hint based State-TTL for StreamingMultiJoinOperator Key: FLINK-37936 URL: https://issues.apache.org/jira/browse/FLINK-37936 Project: Flink

[jira] [Created] (FLINK-37917) Add support for MultiJoinedRowData

Gustavo de Morais created FLINK-37917: - Summary: Add support for MultiJoinedRowData Key: FLINK-37917 URL: https://issues.apache.org/jira/browse/FLINK-37917 Project: Flink Issue Type: New

[jira] [Created] (FLINK-37916) FLIP-516: Add StreamPhysicalMultiJoin physical node

Gustavo de Morais created FLINK-37916: - Summary: FLIP-516: Add StreamPhysicalMultiJoin physical node Key: FLINK-37916 URL: https://issues.apache.org/jira/browse/FLINK-37916 Project: Flink

[jira] [Created] (FLINK-37910) FLIP-516: Add StreamExecMultiJoin exec node

Gustavo de Morais created FLINK-37910: - Summary: FLIP-516: Add StreamExecMultiJoin exec node Key: FLINK-37910 URL: https://issues.apache.org/jira/browse/FLINK-37910 Project: Flink Issue

Re: [VOTE] FLIP-531: Initiate Flink Agents as a new Sub-Project

+1 non-binding. Kind regards, Gustavo On Tue 3. Jun 2025 at 18:04, Ferenc Csaky wrote: > +1 (binding) > > Looking forward to this! > > Best, > Ferenc > > > On Tuesday, June 3rd, 2025 at 11:32, David Radley > wrote: > > > > > > > +1 non-binding. > > This is a very interesting area for us to add

[jira] [Created] (FLINK-37889) FLIP-516: Add new FlinkLogicalMultiJoin rule

Gustavo de Morais created FLINK-37889: - Summary: FLIP-516: Add new FlinkLogicalMultiJoin rule Key: FLINK-37889 URL: https://issues.apache.org/jira/browse/FLINK-37889 Project: Flink Issue

[jira] [Created] (FLINK-37890) FLIP-516: Extend FlinkLogicalMultiJoin to check for common join key

Gustavo de Morais created FLINK-37890: - Summary: FLIP-516: Extend FlinkLogicalMultiJoin to check for common join key Key: FLINK-37890 URL: https://issues.apache.org/jira/browse/FLINK-37890

Re: Request a permission

Hey Zhe Wang, If you'd to file new Jira tickets, head over to the self-serve apache portal to create an account. After that, you'll have to wait for a PMC member to analyze and approve your request. Reminder: you don't need a Jira account to view o

[jira] [Created] (FLINK-37844) FLIP-516 Optimization: Push down projections for StreamingMultiJoinOperator

Gustavo de Morais created FLINK-37844: - Summary: FLIP-516 Optimization: Push down projections for StreamingMultiJoinOperator Key: FLINK-37844 URL: https://issues.apache.org/jira/browse/FLINK-37844

Re: Re: Re: Re: [DISCUSS] FLIP-486: Introduce a new DeltaJoin

Hey Xuyang, Happy to see the FLIP being approved. Could you reply to the questions above if you have some time? Thanks, Gustavo On Tue, 20 May 2025 at 08:56, Gustavo de Morais wrote: > Hey Xuyang, > > Thanks for proposing this and driving the discussion. In general, a very > inte

Re: [VOTE] FLIP-486: Introduce a new DeltaJoin

+1(non-binding). Thanks Xuyang, Gustavo On Tue 20. May 2025 at 09:44, Lincoln Lee wrote: > +1 (binding) > > > Best, > Lincoln Lee > > > 曹振 <15533273...@163.com> 于2025年5月20日周二 14:55写道： > > > +1(non-binding) > > > > > > > > > > > > > > Best, > > CaoZhen > > Replied Message > > | From |

Re: [VOTE] FLIP-530: Dynamic job configuration

Hi, +1 (non-binding). Thanks, Gustavo On Wed, 21 May 2025 at 08:32, Kartikey Pant wrote: > Hi, > > +1 (non-binding) > > Thanks, Kartikey. > > On Wed, May 21, 2025 at 12:59 AM Roman Khachatryan > wrote: > > > Hi everyone, > > > > I'd like to start a vote on FLIP-530: Dynamic job configuration

Re: [DISCUSS] FLIP-530: Dynamic job configuration

Hi Roman, This is a great and important improvement. +1 for the FLIP and to start voting. Best, Gustavo On Mon, 19 May 2025 at 20:28, Roman Khachatryan wrote: > Thanks everyone for the discussion! > > I'm going to start a voting thread soon unless there are other suggestions > or objections. >

Re: Re: Re: Re: [DISCUSS] FLIP-486: Introduce a new DeltaJoin

Hey Xuyang, Thanks for proposing this and driving the discussion. In general, a very interesting idea. - Can you go a bit in detail on how the optimizer will work in AUTO/FORCE modes? When are we returning an error or falling back to the regular streaming join operator? Do we support, for example

[jira] [Created] (FLINK-37814) FLIP-516: Adjust FlinkJoinToMultiJoinRule for Multi Join Operator

Gustavo de Morais created FLINK-37814: - Summary: FLIP-516: Adjust FlinkJoinToMultiJoinRule for Multi Join Operator Key: FLINK-37814 URL: https://issues.apache.org/jira/browse/FLINK-37814 Project

[RESULT][VOTE] FLIP-516: Multi-Way Join Operator

Hello everyone, I'm very happy to share with you that FLIP-516 [1] has been approved with 6 approving votes (5 binding) [2]. Ron Liu (binding) Zakelly Lan (binding) Hao Li (non-binding) Arvid Heise (binding) Timo Walther (binding) Dawid Wysakowicz (binding) Thanks for the votes and discussions,

Re: [VOTE] FLIP-528: Support EXPLAIN EXECUTE STATEMENT SET Syntax in Flink SQL

+1 (non-binding). Thanks Ramin, Gustavo Am Mo., 12. Mai 2025 um 09:42 Uhr schrieb Dawid Wysakowicz < dwysakow...@apache.org>: > +1(binding) > Best, > Dawid > > On Mon, 12 May 2025 at 09:32, Ramin Gharib > wrote: > > > Hi Flink Community, > > > > As the discussion period for FLIP-528: Support EX

Re: [DISCUSS] FLIP-516: Multi-Way Join Operator

to have your +1 over there as well: https://lists.apache.org/thread/3z70lcpotdx6785dpsrvmncwyfb5mnnw Thanks everyone, Gustavo Am Fr., 9. Mai 2025 um 12:42 Uhr schrieb Gustavo de Morais < gustavopg...@gmail.com>: > Sure, that sounds good. I'll make sure we create a ticket for batch. &g

Re: [DISCUSS] FLIP-516: Multi-Way Join Operator

e epic for the FLIP even if you don't plan to work on that, Gustavo. > > However, we should at least output a warning that this option is not used > in batch until it is. WDYT? > > Best, > > Arvid > > On Fri, May 9, 2025 at 12:33 PM Gustavo de Morais > wrote: >

Re: [DISCUSS] FLIP-516: Multi-Way Join Operator

new config option `table.optimizer.multi-join.enabled`, I > have a question: is this option only effective in streaming mode, what is > its behavior in batch mode? > > Best, > Ron > > Gustavo de Morais 于2025年5月8日周四 00:03写道： > > > Hey Ferenc, that's a great callout. I'll make s

[VOTE] FLIP-516: Multi-Way Join Operator

Hi everyone, I'd like to start voting on FLIP-516: Multi-Way Join Operator [1]. The discussion can be found in this thread [2]. The vote will be open for at least 72 hours, unless there is an objection or not enough votes. Thanks, Gustavo de Morais [1] https://cwiki.apache.org/confl

Re: [DISCUSS] FLIP-516: Multi-Way Join Operator

idea and the given > design. This may be considered already, but IMO we should also add some > high-level details, pros, and cons of enabling this feature to the website > other than the config option description. > > Best, > Ferenc > > > > > On Friday, May 2nd, 2025 at

Re: [VOTE] FLIP-520: Simplify StructuredType handling

+1 (non-binding) Thanks Timo, Gustavo Am Mi., 7. Mai 2025 um 04:58 Uhr schrieb Ron Liu : > +1(binding) > > Best, > Ron > > Hao Li 于2025年5月7日周三 00:08写道： > > > +1 (non-binding) > > > > Thanks for driving this! > > > > Hao > > > > On Tue, May 6, 2025 at 8:27 AM Ferenc Csaky > > wrote: > > > > > +

Re: [DISCUSS] FLIP-516: Multi-Way Join Operator

Hey everyone, I'd be great to start voting next week. Let me know if there are further questions or feedback. Thanks, Gustavo Am Mi., 30. Apr. 2025 um 15:07 Uhr schrieb Gustavo de Morais < gustavopg...@gmail.com>: > Hey Arvid and David, thanks for the feedback! > > The li

Re: [DISCUSS] FLIP-529 Connections in Flink SQL and Table API

Hi Mayank, Thanks for the initiative. Looking at the FLIP, this looks like a well-thought-out proposal that addresses a clear need for more secure and reusable external connections in Flink SQL and Table API. Separating connection details would a valuable improvement. Best Regards, Gustavo Am Fr

Re: [DISCUSS] FLIP-516: Multi-Way Join Operator

the idea and approach LGTM. +1 to proceed. > > Best, > > Arvid > > On Thu, Apr 24, 2025 at 4:58 PM Gustavo de Morais > wrote: > > > Hi everyone, > > > > I'd like to propose FLIP-516: Multi-Way Join Operator [1] for discussion. > > > > C

Re: [DISCUSS] FLIP-527 Support EXPLAIN EXECUTE STATEMENT SET Syntax in Flink SQL

I agree with Martijn. It’s just a better, consistent user experience. Also, we keep backwards compatibility, so I see no reason for not doing it. I’d also be +1 for this. Am Di., 29. Apr. 2025 um 09:42 Uhr schrieb Martijn Visser < martijnvis...@apache.org>: > Hi all, > > Thanks for the FLIP Rami

RE: Re: [DISCUSS] FLIP-527 Support EXPLAIN EXECUTE STATEMENT SET Syntax in Flink SQL

I agree with Martijn. It’s just a better, consistent user experience. Also, we keep backwards compatibility, so I see no reason for not doing it. I’d also be +1 for this. On 2025/04/29 07:40:59 Martijn Visser wrote: > Hi all, > > Thanks for the FLIP Ramin. I would be +1 for this. It creates a

[DISCUSS] FLIP-516: Multi-Way Join Operator

s on INNER/LEFT joins, with plans for future expansion. The operator is opt-in via table.optimizer.multi-join.enabled (default false). PR with the initial version of the operator is available [2]. Happy to be contributing to this community, and looking forward to your feedback and thoughts. Kind rega

RE: [DISCUSS] FLIP-520: Simplify StructuredType handling

Thanks for the small but important changes proposed. IMO, these are essential for dealing with these directly in SQL. On 2025/04/10 05:54:58 Timo Walther wrote: > Hi everyone, > > I would like to start a discussion about FLIP-520: Simplify > StructuredType handling [1]. > > Flink SQL already

[jira] [Created] (FLINK-37695) Parsing for a JSON() function call fail to its position

Gustavo de Morais created FLINK-37695: - Summary: Parsing for a JSON() function call fail to its position Key: FLINK-37695 URL: https://issues.apache.org/jira/browse/FLINK-37695 Project: Flink

Re: Re: [ANNOUNCE] New Apache Flink PMC Member - Sergey Nuyanzin

Congrats, Sergey! Kind regards, Gustavo Am Do., 3. Apr. 2025 um 11:42 Uhr schrieb Shengkai Fang : > Congratulations, Sergey! > > Best, > Shengkai > > Xuyang 于2025年4月3日周四 16:19写道： > > > Cheers, Sergey! > > > > > > -- > > > > Best！ > > Xuyang > > > > > > > > > > > > 在 2025-04-03 15:58:48，

RE: [DISCUSS] FLIP-517: Better Handling of Dynamic Table Primitives with PTFs

+1 That's a great proposal, Timo. I like the proposed simplified syntax. Also, being able to convert from or to a changelog is a really nice to have. Gustavo On 2025/03/21 13:23:37 Timo Walther wrote: > Hi everyone, > > I would like to start a discussion about FLIP-517: Better Handling of > D

RE: [DISCUSS] FLIP-517: Better Handling of Dynamic Table Primitives with PTFs

+1 That's a great proposal, Timo. I like the proposed simplified syntax. Also, being able to convert from or to a changelog is a really nice to have. Gustavo On 2025/03/21 13:23:37 Timo Walther wrote: > Hi everyone, > > I would like to start a discussion about FLIP-517: Better Handling of > Dyna

[jira] [Created] (FLINK-37481) Multi way join operator

Gustavo de Morais created FLINK-37481: - Summary: Multi way join operator Key: FLINK-37481 URL: https://issues.apache.org/jira/browse/FLINK-37481 Project: Flink Issue Type: New Feature

[jira] [Created] (FLINK-37374) Support JSON built-in function for JSON_ARRAY

Gustavo de Morais created FLINK-37374: - Summary: Support JSON built-in function for JSON_ARRAY Key: FLINK-37374 URL: https://issues.apache.org/jira/browse/FLINK-37374 Project: Flink

[jira] [Created] (FLINK-37267) Support WITH ORDINALITY for UNNEST

Gustavo de Morais created FLINK-37267: - Summary: Support WITH ORDINALITY for UNNEST Key: FLINK-37267 URL: https://issues.apache.org/jira/browse/FLINK-37267 Project: Flink Issue Type: New

[jira] [Created] (FLINK-37239) Improve documentation for multiple built-in functions

Gustavo de Morais created FLINK-37239: - Summary: Improve documentation for multiple built-in functions Key: FLINK-37239 URL: https://issues.apache.org/jira/browse/FLINK-37239 Project: Flink

[jira] [Created] (FLINK-37178) Improve documentation for BTRIM, TRANSLATE3, ELT and PERCENTILE

Gustavo de Morais created FLINK-37178: - Summary: Improve documentation for BTRIM, TRANSLATE3, ELT and PERCENTILE Key: FLINK-37178 URL: https://issues.apache.org/jira/browse/FLINK-37178 Project

[jira] [Created] (FLINK-37177) Update chinese documentation of json function

Gustavo de Morais created FLINK-37177: - Summary: Update chinese documentation of json function Key: FLINK-37177 URL: https://issues.apache.org/jira/browse/FLINK-37177 Project: Flink

[jira] [Created] (FLINK-37176) setup_hugo.sh doesn't work on macbook

Gustavo de Morais created FLINK-37176: - Summary: setup_hugo.sh doesn't work on macbook Key: FLINK-37176 URL: https://issues.apache.org/jira/browse/FLINK-37176 Project: Flink Issue

[jira] [Created] (FLINK-37175) Support JSON built-in function for JSON_OBJECT

Gustavo de Morais created FLINK-37175: - Summary: Support JSON built-in function for JSON_OBJECT Key: FLINK-37175 URL: https://issues.apache.org/jira/browse/FLINK-37175 Project: Flink

[jira] [Created] (FLINK-36910) Support calling time-related dynamic functions with parenthesis

Gustavo de Morais created FLINK-36910: - Summary: Support calling time-related dynamic functions with parenthesis Key: FLINK-36910 URL: https://issues.apache.org/jira/browse/FLINK-36910 Project

[jira] [Created] (FLINK-36841) Incorrect error message for CURRENT_TIMESTAMP

Gustavo de Morais created FLINK-36841: - Summary: Incorrect error message for CURRENT_TIMESTAMP Key: FLINK-36841 URL: https://issues.apache.org/jira/browse/FLINK-36841 Project: Flink

[jira] [Created] (FLINK-36840) Multiple time-related built-in functions cannot be called

Gustavo de Morais created FLINK-36840: - Summary: Multiple time-related built-in functions cannot be called Key: FLINK-36840 URL: https://issues.apache.org/jira/browse/FLINK-36840 Project: Flink

[jira] [Created] (FLINK-36809) Add ifNotExists param to createTable

Gustavo de Morais created FLINK-36809: - Summary: Add ifNotExists param to createTable Key: FLINK-36809 URL: https://issues.apache.org/jira/browse/FLINK-36809 Project: Flink Issue Type