Re: [VOTE] FLIP-507: Add Model DDL methods in TABLE API

Hi Timo, Thank you for your feedback. I have updated the FLIP to address your questions and concerns. Please let me know if you have any other feedback. Thanks, Yash Anand On Tue, Mar 11, 2025 at 5:55 AM Timo Walther wrote: > Hi Yash, > > thanks for updating the FLIP. > > Here is more feedback

Re: [VOTE] FLIP-513: Split-level watermark metrics

+1 (binding) Best, Stefan > On 17. Mar 2025, at 11:04, Efrat Levitan wrote: > > Hi everyone, > > I'd like to start a vote on FLIP-513: Split-level watermark metrics [1] > which has been discussed in this thread [2]. > The vote will be open for at least 72 hours unless there is an objection o

[jira] [Created] (FLINK-37484) unbounded-chunk-first.enabled no use in unevently chunk split

Hongshun Wang created FLINK-37484: - Summary: unbounded-chunk-first.enabled no use in unevently chunk split Key: FLINK-37484 URL: https://issues.apache.org/jira/browse/FLINK-37484 Project: Flink

[jira] [Created] (FLINK-37485) StarRocks Pipeline connector supports TIME type mapping

yux created FLINK-37485: --- Summary: StarRocks Pipeline connector supports TIME type mapping Key: FLINK-37485 URL: https://issues.apache.org/jira/browse/FLINK-37485 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-37489) CLONE - Other announcements

Weijie Guo created FLINK-37489: -- Summary: CLONE - Other announcements Key: FLINK-37489 URL: https://issues.apache.org/jira/browse/FLINK-37489 Project: Flink Issue Type: Sub-task Repo

[jira] [Created] (FLINK-37491) CLONE - Build 1.20 docs in GitHub Action and mark 1.20 as stable in docs

Weijie Guo created FLINK-37491: -- Summary: CLONE - Build 1.20 docs in GitHub Action and mark 1.20 as stable in docs Key: FLINK-37491 URL: https://issues.apache.org/jira/browse/FLINK-37491 Project: Flink

[jira] [Created] (FLINK-37494) CLONE - Update reference data for Migration Tests

Weijie Guo created FLINK-37494: -- Summary: CLONE - Update reference data for Migration Tests Key: FLINK-37494 URL: https://issues.apache.org/jira/browse/FLINK-37494 Project: Flink Issue Type: Sub

[jira] [Created] (FLINK-37490) CLONE - Updates the docs stable version

Weijie Guo created FLINK-37490: -- Summary: CLONE - Updates the docs stable version Key: FLINK-37490 URL: https://issues.apache.org/jira/browse/FLINK-37490 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-37499) CLONE - Create Git tag and mark version as released in Jira

Weijie Guo created FLINK-37499: -- Summary: CLONE - Create Git tag and mark version as released in Jira Key: FLINK-37499 URL: https://issues.apache.org/jira/browse/FLINK-37499 Project: Flink Iss

[jira] [Created] (FLINK-37496) Finalize release 2.0.0

Weijie Guo created FLINK-37496: -- Summary: Finalize release 2.0.0 Key: FLINK-37496 URL: https://issues.apache.org/jira/browse/FLINK-37496 Project: Flink Issue Type: New Feature Report

[jira] [Created] (FLINK-37495) CLONE - Start End of Life discussion thread for now outdated Flink minor version

Weijie Guo created FLINK-37495: -- Summary: CLONE - Start End of Life discussion thread for now outdated Flink minor version Key: FLINK-37495 URL: https://issues.apache.org/jira/browse/FLINK-37495 Project:

[jira] [Created] (FLINK-37500) CLONE - Publish the Dockerfiles for the new release

Weijie Guo created FLINK-37500: -- Summary: CLONE - Publish the Dockerfiles for the new release Key: FLINK-37500 URL: https://issues.apache.org/jira/browse/FLINK-37500 Project: Flink Issue Type: S

[jira] [Created] (FLINK-37498) CLONE - Deploy artifacts to Maven Central Repository

Weijie Guo created FLINK-37498: -- Summary: CLONE - Deploy artifacts to Maven Central Repository Key: FLINK-37498 URL: https://issues.apache.org/jira/browse/FLINK-37498 Project: Flink Issue Type:

[jira] [Created] (FLINK-37492) CLONE - Remove outdated versions

Weijie Guo created FLINK-37492: -- Summary: CLONE - Remove outdated versions Key: FLINK-37492 URL: https://issues.apache.org/jira/browse/FLINK-37492 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-37497) CLONE - Deploy Python artifacts to PyPI

Weijie Guo created FLINK-37497: -- Summary: CLONE - Deploy Python artifacts to PyPI Key: FLINK-37497 URL: https://issues.apache.org/jira/browse/FLINK-37497 Project: Flink Issue Type: Sub-task

Re: [VOTE] FLIP-513: Split-level watermark metrics

+1 (non-binding). Thanks for driving it! Best Regards,Yuepeng Pan At 2025-03-18 08:12:22, "Xiqian YU" wrote: >+1 (non-binding) > >Best Regards, >Xiqian > >2025年3月17日 18:25，Piotr Nowojski 写道： > >+1 (binding) > >best, >Piotrek > >pon., 17 mar 2025 o 11:06 Efrat Levitan napisał(a): > >Hi everyone,

[jira] [Created] (FLINK-37488) CLONE - Apache mailing lists announcements

Weijie Guo created FLINK-37488: -- Summary: CLONE - Apache mailing lists announcements Key: FLINK-37488 URL: https://issues.apache.org/jira/browse/FLINK-37488 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-37487) CLONE - Merge website pull request

Weijie Guo created FLINK-37487: -- Summary: CLONE - Merge website pull request Key: FLINK-37487 URL: https://issues.apache.org/jira/browse/FLINK-37487 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-37493) CLONE - Update japicmp configuration

Weijie Guo created FLINK-37493: -- Summary: CLONE - Update japicmp configuration Key: FLINK-37493 URL: https://issues.apache.org/jira/browse/FLINK-37493 Project: Flink Issue Type: Sub-task

Re: [VOTE] FLIP-513: Split-level watermark metrics

+1 (non-binding) Best Regards, Xiqian 2025年3月17日 18:25，Piotr Nowojski 写道： +1 (binding) best, Piotrek pon., 17 mar 2025 o 11:06 Efrat Levitan napisał(a): Hi everyone, I'd like to start a vote on FLIP-513: Split-level watermark metrics [1] which has been discussed in this thread [2]. The vot

Re: [DISCUSS] The wrong binary artifacts version on nexus for flink-connector-mongodb v2.0.0

Thanks Jiabao for letting us know this issue, I think a new correct release would help users a lot. +1 from my side. From a process perspective, we are fixing the version number of an already released version, not the code in the corresponding version. I think a lightweight release vote should

[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

Re: [DISCUSS] FLIP-512: Add meta information to SQL state connector

Hi All! Without going into too much detail here are my 2 cents regarding the virtual column / catalog metadata / table (connector) discussion for the State metadata. State metadata such as the types of states, their properties, names, sizes etc are all valuable information that can be used to enr

[VOTE] FLIP-513: Split-level watermark metrics

Hi everyone, I'd like to start a vote on FLIP-513: Split-level watermark metrics [1] which has been discussed in this thread [2]. The vote will be open for at least 72 hours unless there is an objection or not enough votes are casted. Efrat [1] https://cwiki.apache.org/confluence/display/FLINK/FL

[jira] [Created] (FLINK-37482) Simplify the code for PrintSinkOutputWriter

Jiaan Geng created FLINK-37482: -- Summary: Simplify the code for PrintSinkOutputWriter Key: FLINK-37482 URL: https://issues.apache.org/jira/browse/FLINK-37482 Project: Flink Issue Type: Improveme

Re: [VOTE] FLIP-513: Split-level watermark metrics

+1 (binding) best, Piotrek pon., 17 mar 2025 o 11:06 Efrat Levitan napisał(a): > Hi everyone, > > I'd like to start a vote on FLIP-513: Split-level watermark metrics [1] > which has been discussed in this thread [2]. > The vote will be open for at least 72 hours unless there is an objection or

Re: [DISCUSS] FLIP-512: Add meta information to SQL state connector

1. State TTL for Value Columns > I’m planning on adding this, and we may collaborate on it in the future. +1 on this, just ping me. 2. Metadata Table vs. Metadata Column After some code digging and POC all I can say that with heavy effort we can maybe add such changes that we're able to show me

[DISCUSS] The wrong binary artifacts version on nexus for flink-connector-mongodb v2.0.0

Hi everyone, In the flink-connector-mongodb v2.0.0 release candidate #2[1], there is an error in the version of the binary artifacts. The versions on nexus are 2.0.0-1.20.0 and 2.0.0-1.19.0, whereas the correct versions should be 2.0.0-1.20 and 2.0.0-1.19. Could the correct versions of the jars

Re: [VOTE] FLIP-513: Split-level watermark metrics

+1 (non-binding) Thanks for the proposal Best Regards Ahmed Hamdy On Mon, 17 Mar 2025 at 13:28, Roman Khachatryan wrote: > +1 (binding) > > Regards, > Roman > > > On Mon, Mar 17, 2025 at 11:06 AM Efrat Levitan > wrote: > > > Hi everyone, > > > > I'd like to start a vote on FLIP-513: Split-lev

RE: [VOTE] FLIP-513: Split-level watermark metrics

+1 (non-binding) Kind regards, Aleksandr On 2025/03/17 10:04:29 Efrat Levitan wrote: > Hi everyone, > > I'd like to start a vote on FLIP-513: Split-level watermark metrics [1] > which has been discussed in this thread [2]. > The vote will be open for at least 72 hours unless there is an objectio

Re: [VOTE] FLIP-513: Split-level watermark metrics

+1 (binding) Regards, Roman On Mon, Mar 17, 2025 at 11:06 AM Efrat Levitan wrote: > Hi everyone, > > I'd like to start a vote on FLIP-513: Split-level watermark metrics [1] > which has been discussed in this thread [2]. > The vote will be open for at least 72 hours unless there is an objection

Re: [DISCUSS] Optimizing metrics refresh: fetch metrics by name

Hi Francesco! I think this would be a reasonable and nice improvement! Cheers, Gyula On Sat, Mar 8, 2025 at 6:17 AM Francesco D wrote: > Hi all, > > I’d like to discuss an issue encountered while using Flink OSS autoscaler > with jobs that have high parallelism (1k+ subtasks). I’ll share the >

Community review process improvement proposal

Hi , In the last Community Health Initiative we talked of improving the Flink process to involve development review. @Robert Metzger suggested I raise a Flip for this. Prior to raising the Fli

[jira] [Created] (FLINK-37483) Native kubernetes clusters losing checkpoint state on FAILED

Max Feng created FLINK-37483: Summary: Native kubernetes clusters losing checkpoint state on FAILED Key: FLINK-37483 URL: https://issues.apache.org/jira/browse/FLINK-37483 Project: Flink Issue T