Re: [VOTE] FLIP-436: Introduce Catalog-related Syntax

2024-04-25 Thread Jane Chan
Hi Yubin, Thanks for your effort. +1 with the display layout change (binding). Best, Jane On Wed, Apr 24, 2024 at 5:28 PM Ahmed Hamdy wrote: > Hi, +1 (non-binding) > Best Regards > Ahmed Hamdy > > > On Wed, 24 Apr 2024 at 09:58, Yubin Li wrote: > > > Hi everyone, > > > > During the

Re: [VOTE] FLIP-445: Support dynamic parallelism inference for HiveSource

2024-04-25 Thread Ron Liu
+1(binding) Best, Ron Rui Fan <1996fan...@gmail.com> 于2024年4月26日周五 12:55写道: > +1(binding) > > Best, > Rui > > On Fri, Apr 26, 2024 at 10:26 AM Muhammet Orazov > wrote: > > > Hey Xia, > > > > +1 (non-binding) > > > > Thanks and best, > > Muhammet > > > > On 2024-04-26 02:21, Xia Sun wrote: > >

Re: [VOTE] FLIP-445: Support dynamic parallelism inference for HiveSource

2024-04-25 Thread Rui Fan
+1(binding) Best, Rui On Fri, Apr 26, 2024 at 10:26 AM Muhammet Orazov wrote: > Hey Xia, > > +1 (non-binding) > > Thanks and best, > Muhammet > > On 2024-04-26 02:21, Xia Sun wrote: > > Hi everyone, > > > > I'd like to start a vote on FLIP-445: Support dynamic parallelism > > inference > > for

Re: [VOTE] FLIP-445: Support dynamic parallelism inference for HiveSource

2024-04-25 Thread Muhammet Orazov
Hey Xia, +1 (non-binding) Thanks and best, Muhammet On 2024-04-26 02:21, Xia Sun wrote: Hi everyone, I'd like to start a vote on FLIP-445: Support dynamic parallelism inference for HiveSource[1] which has been discussed in this thread [2]. The vote will be open for at least 72 hours

[VOTE] FLIP-445: Support dynamic parallelism inference for HiveSource

2024-04-25 Thread Xia Sun
Hi everyone, I'd like to start a vote on FLIP-445: Support dynamic parallelism inference for HiveSource[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. [1]

Re: [DISCUSSION] FLIP-449: Reorganization of flink-connector-jdbc

2024-04-25 Thread Muhammet Orazov
Hey João, Thanks for FLIP proposal! Since proposal is to introduce modules, would it make sense to have another module for APIs (flink-jdbc-connector-api)? For this I would suggest to move all public interfaces (e.g, JdbcRowConverter, JdbcConnectionProvider). And even convert some classes into

Re: Re:[DISCUSSION] FLIP-449: Reorganization of flink-connector-jdbc

2024-04-25 Thread Yuepeng Pan
Hi, Boto. It's already clear enough to me. Thanks for your reply. Best, Yuepeng Pan On 2024/04/25 15:41:01 João Boto wrote: > Hi Pan, > > Users who wish to utilize only one database and prefer not to use > flink-connector-jdbc-${version}.jar + ${database-connector-driver}.jar should > opt

[jira] [Created] (FLINK-35241) Support SQL FLOOR and CEIL functions with SECOND and MINUTE for TIMESTAMP_TLZ

2024-04-25 Thread Alexey Leonov-Vendrovskiy (Jira)
Alexey Leonov-Vendrovskiy created FLINK-35241: - Summary: Support SQL FLOOR and CEIL functions with SECOND and MINUTE for TIMESTAMP_TLZ Key: FLINK-35241 URL:

Re: [VOTE] FLIP-446: Kubernetes Operator State Snapshot CRD

2024-04-25 Thread gongzhongqiang
+1( (non-binding) Best, Zhongqiang Gong Mate Czagany 于2024年4月24日周三 16:06写道: > Hi everyone, > > I'd like to start a vote on the FLIP-446: Kubernetes Operator State > Snapshot CRD [1]. The discussion thread is here [2]. > > The vote will be open for at least 72 hours unless there is an

[jira] [Created] (FLINK-35240) Disable FLUSH_AFTER_WRITE_VALUE to avoid flush per record

2024-04-25 Thread Zhongqiang Gong (Jira)
Zhongqiang Gong created FLINK-35240: --- Summary: Disable FLUSH_AFTER_WRITE_VALUE to avoid flush per record Key: FLINK-35240 URL: https://issues.apache.org/jira/browse/FLINK-35240 Project: Flink

Re: [VOTE] FLIP-446: Kubernetes Operator State Snapshot CRD

2024-04-25 Thread Robert Metzger
Ah, true -- now I remember. Thanks for fixing the wiki page +1 (binding) On Thu, Apr 25, 2024 at 4:40 PM Gyula Fóra wrote: > That's my fault @Robert Metzger , since the new FLIP > process and a lack of confluent access for non-committers this is a bit > tricky to get it sync :) > > Gyula > >

Re: Re:[DISCUSSION] FLIP-449: Reorganization of flink-connector-jdbc

2024-04-25 Thread João Boto
Hi Pan, Users who wish to utilize only one database and prefer not to use flink-connector-jdbc-${version}.jar + ${database-connector-driver}.jar should opt for option 1: flink-connector-jdbc-core-${version}.jar + flink-connector-jdbc-mysql-${version}.jar + ${database-connector-driver}.jar. We

Re: [VOTE] FLIP-446: Kubernetes Operator State Snapshot CRD

2024-04-25 Thread Gyula Fóra
That's my fault @Robert Metzger , since the new FLIP process and a lack of confluent access for non-committers this is a bit tricky to get it sync :) Gyula On Thu, Apr 25, 2024 at 4:17 PM Robert Metzger wrote: > In principle I'm +1 on the proposal, but I think the FLIP in the wiki is > not in

Re: [VOTE] FLIP-446: Kubernetes Operator State Snapshot CRD

2024-04-25 Thread Robert Metzger
In principle I'm +1 on the proposal, but I think the FLIP in the wiki is not in sync with the Google doc. For example in the Wiki FlinkStateSnapshotSpec.backoffLimit is missing. On Thu, Apr 25, 2024 at 3:27 PM Thomas Weise wrote: > +1 (binding) > > > On Wed, Apr 24, 2024 at 5:14 AM Yuepeng Pan

Re: [ DISCUSS ] FLIP-XXX : [Plugin] Enhancing Flink Failure Management in Kubernetes with Dynamic Termination Log Integration

2024-04-25 Thread Swathi C
Thanks everyone for the feedback. Will try to dive deep into Pluggable Enrichers to see how we can incorporate termination-log by using it. Regards, Swathi C On Thu, Apr 25, 2024 at 12:33 PM Martijn Visser wrote: > Hi Swathi C, > > Also including the Dev mailing list. > > If you have a good

Re: [VOTE] FLIP-446: Kubernetes Operator State Snapshot CRD

2024-04-25 Thread Thomas Weise
+1 (binding) On Wed, Apr 24, 2024 at 5:14 AM Yuepeng Pan wrote: > +1(non-binding) > > > Best, > Yuepeng Pan > > At 2024-04-24 16:05:07, "Rui Fan" <1996fan...@gmail.com> wrote: > >+1(binding) > > > >Best, > >Rui > > > >On Wed, Apr 24, 2024 at 4:03 PM Mate Czagany wrote: > > > >> Hi everyone, >

[jira] [Created] (FLINK-35239) 1.19 docs show outdated warning

2024-04-25 Thread Ufuk Celebi (Jira)
Ufuk Celebi created FLINK-35239: --- Summary: 1.19 docs show outdated warning Key: FLINK-35239 URL: https://issues.apache.org/jira/browse/FLINK-35239 Project: Flink Issue Type: Bug

Re:[DISCUSSION] FLIP-449: Reorganization of flink-connector-jdbc

2024-04-25 Thread Yuepeng Pan
Hi, Boto. Thanks for your driving it ! +1 from me on the proposal. Maybe we need to ensure that a simple usage method is provided to users after the refactoring. In the current situation, which supported database does the user intend to use, Users only need to add the

Re: [DISCUSS] FLIP-448: Introduce Pluggable Workflow Scheduler Interface for Materialized Table

2024-04-25 Thread Ron Liu
Hi, Lorenzo and Feng Thanks for joining this thread discussing. Sorry for later response, regarding your question: > About the Operations interfaces, how can they be empty? Should not they provide at least a `run` or `execute` method (similar to the command pattern)? In this way, their

[jira] [Created] (FLINK-35238) AZP is not working since some ci agent unhealthy

2024-04-25 Thread Weijie Guo (Jira)
Weijie Guo created FLINK-35238: -- Summary: AZP is not working since some ci agent unhealthy Key: FLINK-35238 URL: https://issues.apache.org/jira/browse/FLINK-35238 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-35237) Allow Custom HashFunction in PrePartitionOperator for Flink Sink Customization

2024-04-25 Thread zhangdingxin (Jira)
zhangdingxin created FLINK-35237: Summary: Allow Custom HashFunction in PrePartitionOperator for Flink Sink Customization Key: FLINK-35237 URL: https://issues.apache.org/jira/browse/FLINK-35237

[DISCUSSION] FLIP-449: Reorganization of flink-connector-jdbc

2024-04-25 Thread Joao Boto
Hi all, I'd like to start a discussion on FLIP-449: Reorganization of flink-connector-jdbc [1]. As Flink continues to evolve, we've noticed an increasing level of complexity within the JDBC connector. The proposed solution is to address this complexity by separating the core functionality from

[jira] [Created] (FLINK-35236) Flink 1.19 Translation error on the Chinese official website

2024-04-25 Thread hongxu han (Jira)
hongxu han created FLINK-35236: -- Summary: Flink 1.19 Translation error on the Chinese official website Key: FLINK-35236 URL: https://issues.apache.org/jira/browse/FLINK-35236 Project: Flink

[DISCUSSION] FLIP-450: Improve Runtime Configuration for Flink 2.0

2024-04-25 Thread Xuannan Su
Hi all, I'd like to start a discussion on FLIP-450: Improve Runtime Configuration for Flink 2.0 [1]. As Flink moves toward 2.0, we have revisited all runtime configurations and identified several improvements to enhance user-friendliness and maintainability. In this FLIP, we aim to refine the

Re: [DISCUSS] FLIP-445: Support dynamic parallelism inference for HiveSource

2024-04-25 Thread Xia Sun
Hi Venkat, Thanks for joining the discussion. Based on our understanding, there are still a significant number of existing tasks using Hive. Indeed, many companies are now migrating their data to the lakehouse, but due to historical reasons, a substantial amount of data still resides in Hive.

[jira] [Created] (FLINK-35235) Fix missing dependencies in the uber jar

2024-04-25 Thread LvYanquan (Jira)
LvYanquan created FLINK-35235: - Summary: Fix missing dependencies in the uber jar Key: FLINK-35235 URL: https://issues.apache.org/jira/browse/FLINK-35235 Project: Flink Issue Type: Improvement

Re: [ DISCUSS ] FLIP-XXX : [Plugin] Enhancing Flink Failure Management in Kubernetes with Dynamic Termination Log Integration

2024-04-25 Thread Martijn Visser
Hi Swathi C, Also including the Dev mailing list. If you have a good reason for not being able to use the pluggable enricher FLIP, you'll have to include that rationale in your own FLIP and explain it. You might get challenged for it in the Dev mailing list thread discussion, but that's the

CSRF token available in apache flink

2024-04-25 Thread Swathi C
Hi , Is CSRF token available in apache flink or any JIRA which is in-progress ? Regards, Swathi C