[jira] [Created] (FLINK-35177) Datagen examples in documentation do not compile

2024-04-19 Thread Sergei Morozov (Jira)
Sergei Morozov created FLINK-35177: -- Summary: Datagen examples in documentation do not compile Key: FLINK-35177 URL: https://issues.apache.org/jira/browse/FLINK-35177 Project: Flink Issue

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

2024-04-19 Thread Gyula Fóra
Hey! Regarding the question of initialSavepointPath and flinkStateSnapshotReference new object, I think we could simply keep an extra field as part of the flinkStateSnapshotReference object called path. Then the fields could be: namespace, name, path If path is defined we would use that (to

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

2024-04-19 Thread Mate Czagany
Hi Robert and Thomas, Thank you for sharing your thoughts, I will try to address your questions and suggestions: 1. I would really love to hear others' inputs as well about separating the snapshot CRD into two different CRDs instead for savepoints and checkpoints. I think the main upside is that

[jira] [Created] (FLINK-35176) Support property authentication connection for JDBC catalog & dynamic table

2024-04-19 Thread RocMarshal (Jira)
RocMarshal created FLINK-35176: -- Summary: Support property authentication connection for JDBC catalog & dynamic table Key: FLINK-35176 URL: https://issues.apache.org/jira/browse/FLINK-35176 Project:

Re: [VOTE] FLIP-435: Introduce a New Materialized Table for Simplifying Data Pipelines

2024-04-19 Thread Martijn Visser
+1 (binding) On Fri, Apr 19, 2024 at 10:07 AM Yuepeng Pan wrote: > +1(non-binding) > > Best, > Yuepeng Pan > > At 2024-04-19 15:22:04, "gongzhongqiang" > wrote: > >+1(non-binding) > > > > > >Best, > > > >Zhongqiang Gong > > > >Ron liu 于2024年4月17日周三 14:28写道： > > > >> Hi Dev, > >> > >> Thank

[jira] [Created] (FLINK-35175) HadoopDataInputStream can't compile with Hadoop 3.2.3

2024-04-19 Thread Ryan Skraba (Jira)
Ryan Skraba created FLINK-35175: --- Summary: HadoopDataInputStream can't compile with Hadoop 3.2.3 Key: FLINK-35175 URL: https://issues.apache.org/jira/browse/FLINK-35175 Project: Flink Issue

[jira] [Created] (FLINK-35174) Bump org.apache.commons:commons-compress from 1.25.0 to 1.26.1 for Flink RabbitMQ connector

2024-04-19 Thread Danny Cranmer (Jira)
Danny Cranmer created FLINK-35174: - Summary: Bump org.apache.commons:commons-compress from 1.25.0 to 1.26.1 for Flink RabbitMQ connector Key: FLINK-35174 URL: https://issues.apache.org/jira/browse/FLINK-35174

[VOTE] Release flink-connector-aws v4.3.0, release candidate #2

2024-04-19 Thread Danny Cranmer
Hi everyone, Please review and vote on release candidate #2 for flink-connector-aws v4.3.0, as follows: [ ] +1, Approve the release [ ] -1, Do not approve the release (please provide specific comments) This version supports Flink 1.18 and 1.19. The complete staging area is available for your

[jira] [Created] (FLINK-35173) Debezium Custom Time Serializer

2024-04-19 Thread ZhengYu Chen (Jira)
ZhengYu Chen created FLINK-35173: Summary: Debezium Custom Time Serializer Key: FLINK-35173 URL: https://issues.apache.org/jira/browse/FLINK-35173 Project: Flink Issue Type: Improvement

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

2024-04-19 Thread Thomas Weise
Thanks for the proposal. How do you see potential effects on API server performance wrt. number of objects vs mutations? Is the proposal more or less neutral in that regard? Thanks for the thorough feedback Robert. Couple more questions below. --> On Fri, Apr 19, 2024 at 5:07 AM Robert

[jira] [Created] (FLINK-35172) DDL statement is added to the Schema Change Event

2024-04-19 Thread melin (Jira)
melin created FLINK-35172: - Summary: DDL statement is added to the Schema Change Event Key: FLINK-35172 URL: https://issues.apache.org/jira/browse/FLINK-35172 Project: Flink Issue Type: New Feature

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

2024-04-19 Thread Robert Metzger
Hi Mate, thanks for proposing this, I'm really excited about your FLIP. I hope my questions make sense to you: 1. I would like to discuss the "FlinkStateSnapshot" name and the fact that users have to use either the savepoint or checkpoint spec inside the FlinkStateSnapshot. Wouldn't it be more

Re: [VOTE] FLIP-435: Introduce a New Materialized Table for Simplifying Data Pipelines

2024-04-19 Thread Yuepeng Pan
+1(non-binding) Best, Yuepeng Pan At 2024-04-19 15:22:04, "gongzhongqiang" wrote: >+1(non-binding) > > >Best, > >Zhongqiang Gong > >Ron liu 于2024年4月17日周三 14:28写道： > >> Hi Dev, >> >> Thank you to everyone for the feedback on FLIP-435: Introduce a New >> Materialized Table for Simplifying Data

[jira] [Created] (FLINK-35171) Class 'FlinkSqlParserImpl' is missed

2024-04-19 Thread chenyu (Jira)
chenyu created FLINK-35171: -- Summary: Class 'FlinkSqlParserImpl' is missed Key: FLINK-35171 URL: https://issues.apache.org/jira/browse/FLINK-35171 Project: Flink Issue Type: Bug Affects

Re: [VOTE] FLIP-435: Introduce a New Materialized Table for Simplifying Data Pipelines

2024-04-19 Thread gongzhongqiang
+1(non-binding) Best, Zhongqiang Gong Ron liu 于2024年4月17日周三 14:28写道： > Hi Dev, > > Thank you to everyone for the feedback on FLIP-435: Introduce a New > Materialized Table for Simplifying Data Pipelines[1][2]. > > I'd like to start a vote for it. The vote will be open for at least 72 > hours

[jira] [Created] (FLINK-35170) SqlServer connector support scanNewlyAddedTableEnabled param

2024-04-19 Thread fengfengzai (Jira)
fengfengzai created FLINK-35170: --- Summary: SqlServer connector support scanNewlyAddedTableEnabled param Key: FLINK-35170 URL: https://issues.apache.org/jira/browse/FLINK-35170 Project: Flink

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

2024-04-19 Thread Gyula Fóra
Cc'ing some folks who gave positive feedback on this idea in the past. I would love to hear your thoughts on the proposed design Gyula On Tue, Apr 16, 2024 at 6:31 PM Őrhidi Mátyás wrote: > +1 Looking forward to it > > On Tue, Apr 16, 2024 at 8:56 AM Mate Czagany wrote: > > > Thank you