[DISCUSS] Releasing Amazon DynamoDB Connector v2.0.0

2022-11-23 Thread Danny Cranmer
Hello all, I would like to start discussing the first release of the new Amazon DynamoDB sink connector [1], along with the new AWS connector parent [2] at version 2.0.0. As per the connector versioning strategy [3] from the new flink-connector-aws repository [4]. We are aiming to create the relea

[jira] [Created] (FLINK-30162) Remove unused arguments/methods/classes

2022-11-23 Thread Chesnay Schepler (Jira)
Chesnay Schepler created FLINK-30162: Summary: Remove unused arguments/methods/classes Key: FLINK-30162 URL: https://issues.apache.org/jira/browse/FLINK-30162 Project: Flink Issue Type: T

Re: [ANNOUNCE] New Apache Flink PMC Members - Godfrey He, Xingbo Huang

2022-11-23 Thread Jane Chan
Congratulations, Godfrey and Xinbo! Best, Jane Chan On Wed, Nov 23, 2022 at 3:34 PM Wei Zhong wrote: > Congratulations, Godfrey and Xingbo! > > Best, > Wei > > > 2022年11月23日 下午3:29,Shuiqiang Chen 写道: > > > > Congratulations, Godfrey and Xingbo! > > > > Best, > > Shuiqiang > > > > Runker Hanna

[jira] [Created] (FLINK-30163) StreamPandasUDFITTests.test_basic_functionality failed

2022-11-23 Thread Matthias Pohl (Jira)
Matthias Pohl created FLINK-30163: - Summary: StreamPandasUDFITTests.test_basic_functionality failed Key: FLINK-30163 URL: https://issues.apache.org/jira/browse/FLINK-30163 Project: Flink Issu

Re: [ANNOUNCE] New Apache Flink PMC Members - Godfrey He, Xingbo Huang

2022-11-23 Thread Danny Cranmer
Congrats both! Welcome :) Danny On Wed, Nov 23, 2022 at 9:02 AM Jane Chan wrote: > Congratulations, Godfrey and Xinbo! > > Best, > Jane Chan > > On Wed, Nov 23, 2022 at 3:34 PM Wei Zhong wrote: > > > Congratulations, Godfrey and Xingbo! > > > > Best, > > Wei > > > > > 2022年11月23日 下午3:29,Shuiqi

[jira] [Created] (FLINK-30164) Expose BucketComputer from SupportsWrite

2022-11-23 Thread Jingsong Lee (Jira)
Jingsong Lee created FLINK-30164: Summary: Expose BucketComputer from SupportsWrite Key: FLINK-30164 URL: https://issues.apache.org/jira/browse/FLINK-30164 Project: Flink Issue Type: Improvem

[jira] [Created] (FLINK-30165) [JUnit5 Migration] Migrate unaligned checkpoint related tests under flink-runtime module to junit5

2022-11-23 Thread Rui Fan (Jira)
Rui Fan created FLINK-30165: --- Summary: [JUnit5 Migration] Migrate unaligned checkpoint related tests under flink-runtime module to junit5 Key: FLINK-30165 URL: https://issues.apache.org/jira/browse/FLINK-30165

Re: [ANNOUNCE] New Apache Flink PMC Members - Godfrey He, Xingbo Huang

2022-11-23 Thread yu zelin
Congratulations,Godfrey and Xingbo! Best, Yu Zelin > 2022年11月23日 12:18,Dian Fu 写道: > > Hi everyone, > > On behalf of the Apache Flink PMC, I'm very happy to announce that Godfrey > He and Xingbo Huang have joined the Flink PMC! > > Godfrey He becomes a Flink committer in Sep 2020. His contribu

Re: Re: [DISCUSS] FLIP-269: Properly Handling the Processing Timers on Job Termination

2022-11-23 Thread Piotr Nowojski
Hi Divye I think we are mostly on the same page. Just to clarify/rephrase: > One thing to think about - on EOF “trigger immediately” will mean that the > asynchronous wait timeout timers will also fire - which is undesirable I didn't mean to fire all timers immediately in all of the built-in ope

[jira] [Created] (FLINK-30166) Refactor tests that use the deprecated StreamingFileSink instead of FileSink

2022-11-23 Thread Martijn Visser (Jira)
Martijn Visser created FLINK-30166: -- Summary: Refactor tests that use the deprecated StreamingFileSink instead of FileSink Key: FLINK-30166 URL: https://issues.apache.org/jira/browse/FLINK-30166 Proj

[RESULT][VOTE] FLIP-272: Generalized delegation token support

2022-11-23 Thread Gabor Somogyi
Hi All, The proposal [1] has been accepted. Binding votes in favour: Marton Balassi Danny Cranmer Gyula Fora Non-binding: Ferenc Csaky there were no votes against. BR, G [1] https://cwiki.apache.org/confluence/display/FLINK/FLIP-272%3A+Generalized+delegation+token+support

[jira] [Created] (FLINK-30167) Upgrade japicmp to 1.17.1

2022-11-23 Thread Chesnay Schepler (Jira)
Chesnay Schepler created FLINK-30167: Summary: Upgrade japicmp to 1.17.1 Key: FLINK-30167 URL: https://issues.apache.org/jira/browse/FLINK-30167 Project: Flink Issue Type: Technical Debt

[jira] [Created] (FLINK-30168) PyFlink Deserialization Error with Object Array

2022-11-23 Thread Yunfeng Zhou (Jira)
Yunfeng Zhou created FLINK-30168: Summary: PyFlink Deserialization Error with Object Array Key: FLINK-30168 URL: https://issues.apache.org/jira/browse/FLINK-30168 Project: Flink Issue Type: I

[jira] [Created] (FLINK-30169) Adds version switcher in PyFlink API doc

2022-11-23 Thread Xingbo Huang (Jira)
Xingbo Huang created FLINK-30169: Summary: Adds version switcher in PyFlink API doc Key: FLINK-30169 URL: https://issues.apache.org/jira/browse/FLINK-30169 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-30170) Update Parquet version to 1.12.3

2022-11-23 Thread Martijn Visser (Jira)
Martijn Visser created FLINK-30170: -- Summary: Update Parquet version to 1.12.3 Key: FLINK-30170 URL: https://issues.apache.org/jira/browse/FLINK-30170 Project: Flink Issue Type: Technical De

[jira] [Created] (FLINK-30171) Bump socket.io-parser from 4.0.4 to 4.0.5

2022-11-23 Thread Martijn Visser (Jira)
Martijn Visser created FLINK-30171: -- Summary: Bump socket.io-parser from 4.0.4 to 4.0.5 Key: FLINK-30171 URL: https://issues.apache.org/jira/browse/FLINK-30171 Project: Flink Issue Type: Tec

[jira] [Created] (FLINK-30172) Bump loader-utils from 2.0.2 to 2.0.4

2022-11-23 Thread Martijn Visser (Jira)
Martijn Visser created FLINK-30172: -- Summary: Bump loader-utils from 2.0.2 to 2.0.4 Key: FLINK-30172 URL: https://issues.apache.org/jira/browse/FLINK-30172 Project: Flink Issue Type: Technic

[jira] [Created] (FLINK-30173) Upgrade @angular-devkit/build-angular from 14.2.6 to 15.0.0

2022-11-23 Thread Martijn Visser (Jira)
Martijn Visser created FLINK-30173: -- Summary: Upgrade @angular-devkit/build-angular from 14.2.6 to 15.0.0 Key: FLINK-30173 URL: https://issues.apache.org/jira/browse/FLINK-30173 Project: Flink

[jira] [Created] (FLINK-30174) Bump engine.io from 6.2.0 to 6.2.1

2022-11-23 Thread Martijn Visser (Jira)
Martijn Visser created FLINK-30174: -- Summary: Bump engine.io from 6.2.0 to 6.2.1 Key: FLINK-30174 URL: https://issues.apache.org/jira/browse/FLINK-30174 Project: Flink Issue Type: Technical

[jira] [Created] (FLINK-30175) Bump snakeyaml from 1.31 to 1.32

2022-11-23 Thread Martijn Visser (Jira)
Martijn Visser created FLINK-30175: -- Summary: Bump snakeyaml from 1.31 to 1.32 Key: FLINK-30175 URL: https://issues.apache.org/jira/browse/FLINK-30175 Project: Flink Issue Type: Technical De

Re: [ANNOUNCE] New Apache Flink PMC Members - Godfrey He, Xingbo Huang

2022-11-23 Thread Konstantin Knauf
Congrats to both. Am Mi., 23. Nov. 2022 um 10:45 Uhr schrieb yu zelin : > Congratulations,Godfrey and Xingbo! > > Best, > Yu Zelin > > 2022年11月23日 12:18,Dian Fu 写道: > > > > Hi everyone, > > > > On behalf of the Apache Flink PMC, I'm very happy to announce that > Godfrey > > He and Xingbo Huang h

[jira] [Created] (FLINK-30176) assert_available_slots is passing even if curl is timing out

2022-11-23 Thread Gabor Somogyi (Jira)
Gabor Somogyi created FLINK-30176: - Summary: assert_available_slots is passing even if curl is timing out Key: FLINK-30176 URL: https://issues.apache.org/jira/browse/FLINK-30176 Project: Flink

Re: [ANNOUNCE] New Apache Flink PMC Members - Godfrey He, Xingbo Huang

2022-11-23 Thread Rui Fan
Congratulations, well deserved! Rui Fan On Wed, Nov 23, 2022 at 9:53 PM Konstantin Knauf wrote: > Congrats to both. > > Am Mi., 23. Nov. 2022 um 10:45 Uhr schrieb yu zelin >: > > > Congratulations,Godfrey and Xingbo! > > > > Best, > > Yu Zelin > > > 2022年11月23日 12:18,Dian Fu 写道: > > > > > > H

Re: [ANNOUNCE] New Apache Flink Committer - Matyas Orhidi

2022-11-23 Thread Martijn Visser
Congratulations and welcome! On Wed, Nov 23, 2022 at 2:25 AM yuxia wrote: > Congrats Matyas! > > Best regards, > Yuxia > > - 原始邮件 - > 发件人: "Peter Huang" > 收件人: "dev" > 发送时间: 星期三, 2022年 11 月 23日 上午 8:24:00 > 主题: Re: [ANNOUNCE] New Apache Flink Committer - Matyas Orhidi > > Congrats! > >

Re: Table API thrift support

2022-11-23 Thread Martijn Visser
Hi Chen, I'm a bit skeptical of shading Thrift libraries from the Hive connector, especially with the plans to externalize connectors (including Hive). Have we considered getting the versions in sync to avoid the need of any shading? The FLIP also shows a version of Thrift (0.5.0-p6) that I don't

Re: [VOTE] Release flink-shaded 16.1, release candidate #1

2022-11-23 Thread Piotr Nowojski
+1 (binding) czw., 10 lis 2022 o 11:38 Martijn Visser napisał(a): > +1 (binding) > > - Validated hashes > - Verified signature > - Verified that no binaries exist in the source archive > - Build the source with Maven > - Verified licenses > - Verified web PR > > > On Tue, Nov 8, 2022 at 11:48 AM

Re: [ANNOUNCE] New Apache Flink Committer - Matyas Orhidi

2022-11-23 Thread Lincoln Lee
Congrats! Best, Lincoln Lee Martijn Visser 于2022年11月23日周三 22:32写道: > Congratulations and welcome! > > On Wed, Nov 23, 2022 at 2:25 AM yuxia wrote: > > > Congrats Matyas! > > > > Best regards, > > Yuxia > > > > - 原始邮件 - > > 发件人: "Peter Huang" > > 收件人: "dev" > > 发送时间: 星期三, 2022年 11 月

Re: [VOTE] Release flink-shaded 16.1, release candidate #1

2022-11-23 Thread Timo Walther
+1 (binding) Thanks, Timo On 23.11.22 15:53, Piotr Nowojski wrote: +1 (binding) czw., 10 lis 2022 o 11:38 Martijn Visser napisał(a): +1 (binding) - Validated hashes - Verified signature - Verified that no binaries exist in the source archive - Build the source with Maven - Verified license

Re: [DISCUSS] Updating Flink HBase Connectors

2022-11-23 Thread Martijn Visser
Hi Ferenc, The repository is there https://github.com/apache/flink-connector-hbase You know where to reach out to if you have any questions. Best regards, Martijn On Mon, Nov 21, 2022 at 12:42 PM Ferenc Csaky wrote: > Hi! > > Sure, thank you both for the input. If the repo is ready, I'll star

Re: [ANNOUNCE] New Apache Flink Committer - Matyas Orhidi

2022-11-23 Thread Maximilian Michels
Congrats Matyas! Finally :) On Wed, Nov 23, 2022 at 3:32 PM Martijn Visser wrote: > Congratulations and welcome! > > On Wed, Nov 23, 2022 at 2:25 AM yuxia wrote: > > > Congrats Matyas! > > > > Best regards, > > Yuxia > > > > - 原始邮件 - > > 发件人: "Peter Huang" > > 收件人: "dev" > > 发送时间: 星期三

Re: [DISCUSS] FLIP-271: Autoscaling

2022-11-23 Thread Maximilian Michels
Thanks for your comments @Dong and @Chen. It is true that not all the details are contained in the FLIP. The document is meant as a general design concept. As for the rescaling time, this is going to be a configurable setting for now but it is foreseeable that we will provide auto-tuning of this c

[VOTE] FLIP-271: Autoscaling

2022-11-23 Thread Maximilian Michels
Hi everyone, I'd like to start a vote for FLIP-271 [1] which we previously discussed on the dev mailing list [2]. I'm planning to keep the vote open for at least until Tuesday, Nov 29. -Max [1] https://cwiki.apache.org/confluence/display/FLINK/FLIP-271%3A+Autoscaling [2] https://lists.apache.or

Re: [DISCUSS] OLM Bundles for Flink Kubernetes Operator

2022-11-23 Thread Gyula Fóra
Ted, Jim: When we create the RC bundle (jars, sources, helm chart) we execute the following steps: 1. Push the RC tag to git -> this will generate and publish an image with the RC git commit tag to ghcr.io 2. We bake into the helm chart the RC tag as the image tag 3. We create the source and he

Re: [ANNOUNCE] New Apache Flink PMC Members - Godfrey He, Xingbo Huang

2022-11-23 Thread Yun Tang
Congratulations, Godfrey and Xingbo! Best Yun Tang From: Rui Fan <1996fan...@gmail.com> Sent: Wednesday, November 23, 2022 22:31 To: dev@flink.apache.org Subject: Re: [ANNOUNCE] New Apache Flink PMC Members - Godfrey He, Xingbo Huang Congratulations, well deserve

Re: [ANNOUNCE] New Apache Flink PMC Members - Godfrey He, Xingbo Huang

2022-11-23 Thread Maximilian Michels
Welcome aboard Godfrey and Xingbo! -Max On Wed, Nov 23, 2022 at 5:51 PM Yun Tang wrote: > Congratulations, Godfrey and Xingbo! > > Best > Yun Tang > > From: Rui Fan <1996fan...@gmail.com> > Sent: Wednesday, November 23, 2022 22:31 > To: dev@flink.apache.org > S

Re: FRocksDB Some Question

2022-11-23 Thread Yun Tang
Hi ConradJam, Thanks for taking a look at the FRocksDB project. >From my point of view, the reasons why Flink community would not upgrade the >FRocksDB too frequently are mainly due to: 1. We have suffered from the performance regression of new versions of RocksDB compared with current vers

Re: [ANNOUNCE] New Apache Flink PMC Members - Godfrey He, Xingbo Huang

2022-11-23 Thread Jing Ge
Congrats, Godfrey! Congrats, Xingbo! Best regards, Jing On Wed, Nov 23, 2022 at 6:11 PM Maximilian Michels wrote: > Welcome aboard Godfrey and Xingbo! > > -Max > > On Wed, Nov 23, 2022 at 5:51 PM Yun Tang wrote: > > > Congratulations, Godfrey and Xingbo! > > > > Best > > Yun Tang > > _

Re: [VOTE] FLIP-271: Autoscaling

2022-11-23 Thread Gyula Fóra
+1 (binding) Gyula On Wed, Nov 23, 2022 at 5:25 PM Maximilian Michels wrote: > Hi everyone, > > I'd like to start a vote for FLIP-271 [1] which we previously discussed > on the dev mailing list [2]. > > I'm planning to keep the vote open for at least until Tuesday, Nov 29. > > -Max > > [1] > ht

[jira] [Created] (FLINK-30177) Update pgjdbc to fix CVE-2022-41946

2022-11-23 Thread Sergey Nuyanzin (Jira)
Sergey Nuyanzin created FLINK-30177: --- Summary: Update pgjdbc to fix CVE-2022-41946 Key: FLINK-30177 URL: https://issues.apache.org/jira/browse/FLINK-30177 Project: Flink Issue Type: Technic

[jira] [Created] (FLINK-30178) Kubernetes test failed with "crictl: command not found"

2022-11-23 Thread Martijn Visser (Jira)
Martijn Visser created FLINK-30178: -- Summary: Kubernetes test failed with "crictl: command not found" Key: FLINK-30178 URL: https://issues.apache.org/jira/browse/FLINK-30178 Project: Flink I

Re: Re: [DISCUSS] FLIP-269: Properly Handling the Processing Timers on Job Termination

2022-11-23 Thread Divye Kapoor
Sounds good. Looks like we're on the same page. Thanks! Divye On Wed, Nov 23, 2022 at 2:41 AM Piotr Nowojski wrote: > Hi Divye > > I think we are mostly on the same page. Just to clarify/rephrase: > > > One thing to think about - on EOF “trigger immediately” will mean that > the > > asynchronou

[jira] [Created] (FLINK-30179) Stop stringifying exception for logging

2022-11-23 Thread Mingliang Liu (Jira)
Mingliang Liu created FLINK-30179: - Summary: Stop stringifying exception for logging Key: FLINK-30179 URL: https://issues.apache.org/jira/browse/FLINK-30179 Project: Flink Issue Type: Improve

Re: [ANNOUNCE] New Apache Flink PMC Members - Godfrey He, Xingbo Huang

2022-11-23 Thread Yang Wang
Congratulations, Godfrey and Xingbo! Best, Yang Jing Ge 于2022年11月24日周四 02:06写道: > Congrats, Godfrey! Congrats, Xingbo! > > Best regards, > Jing > > On Wed, Nov 23, 2022 at 6:11 PM Maximilian Michels wrote: > > > Welcome aboard Godfrey and Xingbo! > > > > -Max > > > > On Wed, Nov 23, 2022 at 5:

Re: [DISCUSS] OLM Bundles for Flink Kubernetes Operator

2022-11-23 Thread Yang Wang
Improving the visibility of Flink Kubernetes Operator is great. And I agree OLM could help with this. I just hope this will not make the whole release process too complicated. Of course, if we want to integrate the OLM into the official release, it should be tested by the users easily. Best, Yang

Re: [ANNOUNCE] New Apache Flink Committer - Matyas Orhidi

2022-11-23 Thread Yang Wang
Congrats Matyas! Best, Yang Maximilian Michels 于2022年11月23日周三 23:27写道: > Congrats Matyas! Finally :) > > On Wed, Nov 23, 2022 at 3:32 PM Martijn Visser > wrote: > > > Congratulations and welcome! > > > > On Wed, Nov 23, 2022 at 2:25 AM yuxia > wrote: > > > > > Congrats Matyas! > > > > > > Bes

Re: [ANNOUNCE] New Apache Flink PMC Members - Godfrey He, Xingbo Huang

2022-11-23 Thread Yanfei Lei
Congrats,Godfrey and Xingbo! Best, Yanfei Yang Wang 于2022年11月24日周四 09:32写道: > Congratulations, Godfrey and Xingbo! > > Best, > Yang > > Jing Ge 于2022年11月24日周四 02:06写道: > > > Congrats, Godfrey! Congrats, Xingbo! > > > > Best regards, > > Jing > > > > On Wed, Nov 23, 2022 at 6:11 PM Maximilian M

[jira] [Created] (FLINK-30180) Remove the description of Filesystem supporting for the lookup in the Supported Connectors section

2022-11-23 Thread Xianxun Ye (Jira)
Xianxun Ye created FLINK-30180: -- Summary: Remove the description of Filesystem supporting for the lookup in the Supported Connectors section Key: FLINK-30180 URL: https://issues.apache.org/jira/browse/FLINK-30180

[jira] [Created] (FLINK-30181) MultiInputCheckpointingTimeBenchmark.checkpointMultiInput benchmark failed

2022-11-23 Thread Yanfei Lei (Jira)
Yanfei Lei created FLINK-30181: -- Summary: MultiInputCheckpointingTimeBenchmark.checkpointMultiInput benchmark failed Key: FLINK-30181 URL: https://issues.apache.org/jira/browse/FLINK-30181 Project: Flink

Fwd: Physical memory and Auto Memory settings in TM

2022-11-23 Thread ramkrishna vasudevan
Hi All, (Sending to dev@ ) Installation of flink clusters where we govern the memory configs by specifying 'taskmanager.memory.process.size' TM memory is auto calculated. But in this calculation we generally don't check the actual physical memory available. So in case of a wrong configuration wher

Re: [ANNOUNCE] New Apache Flink PMC Members - Godfrey He, Xingbo Huang

2022-11-23 Thread Shuo Cheng
Congratulations, Godfrey and Xingbo! Best, Shuo On Wed, Nov 23, 2022 at 12:19 PM Dian Fu wrote: > Hi everyone, > > On behalf of the Apache Flink PMC, I'm very happy to announce that Godfrey > He and Xingbo Huang have joined the Flink PMC! > > Godfrey He becomes a Flink committer in Sep 2020. Hi

Re: [ANNOUNCE] New Apache Flink PMC Members - Godfrey He, Xingbo Huang

2022-11-23 Thread Shengkai Fang
Congratulations, Godfrey and Xingbo! Best, Shengkai Shuo Cheng 于2022年11月24日周四 10:56写道: > Congratulations, Godfrey and Xingbo! > > Best, > Shuo > > On Wed, Nov 23, 2022 at 12:19 PM Dian Fu wrote: > > > Hi everyone, > > > > On behalf of the Apache Flink PMC, I'm very happy to announce that > God

[jira] [Created] (FLINK-30182) Create template for release announcement

2022-11-23 Thread Matthias Pohl (Jira)
Matthias Pohl created FLINK-30182: - Summary: Create template for release announcement Key: FLINK-30182 URL: https://issues.apache.org/jira/browse/FLINK-30182 Project: Flink Issue Type: Improv

Re: [VOTE] FLIP-271: Autoscaling

2022-11-23 Thread Őrhidi Mátyás
+1 (binding) On Wed, Nov 23, 2022 at 11:46 AM Gyula Fóra wrote: > +1 (binding) > > Gyula > > On Wed, Nov 23, 2022 at 5:25 PM Maximilian Michels wrote: > > > Hi everyone, > > > > I'd like to start a vote for FLIP-271 [1] which we previously discussed > > on the dev mailing list [2]. > > > > I'm

Re: SQL Gateway and SQL Client

2022-11-23 Thread yu zelin
Hi Jim, Sorry for incorrect message in last reply. > Shengkai will help to your PR I mean Shengkai will help to review the PRs. And I will add some of your suggestion to my design. I think the POC code will be cherry-picked to my new design of SQL Client. > 2022年11月23日 12:18,yu zelin 写道: > > H

Re: [ANNOUNCE] New Apache Flink PMC Members - Godfrey He, Xingbo Huang

2022-11-23 Thread Matthias Pohl
Congratulations to the two of you! Best, Matthias On Thu, Nov 24, 2022 at 11:29 AM Shengkai Fang wrote: > Congratulations, Godfrey and Xingbo! > > Best, > Shengkai > > Shuo Cheng 于2022年11月24日周四 10:56写道: > > > Congratulations, Godfrey and Xingbo! > > > > Best, > > Shuo > > > > On Wed, Nov 23, 2

[jira] [Created] (FLINK-30183) We should add a proper error message in case the deprecated reflection-based instantiation of a reporter is triggered

2022-11-23 Thread Matthias Pohl (Jira)
Matthias Pohl created FLINK-30183: - Summary: We should add a proper error message in case the deprecated reflection-based instantiation of a reporter is triggered Key: FLINK-30183 URL: https://issues.apache.org/ji

[jira] [Created] (FLINK-30184) Save TM/JM thread stack periodically

2022-11-23 Thread Rui Fan (Jira)
Rui Fan created FLINK-30184: --- Summary: Save TM/JM thread stack periodically Key: FLINK-30184 URL: https://issues.apache.org/jira/browse/FLINK-30184 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-30185) Provide the flame graph to the subtask level

2022-11-23 Thread Rui Fan (Jira)
Rui Fan created FLINK-30185: --- Summary: Provide the flame graph to the subtask level Key: FLINK-30185 URL: https://issues.apache.org/jira/browse/FLINK-30185 Project: Flink Issue Type: Improvement

Re: [DISCUSS] FLIP-273: Improve Catalog API to Support ALTER TABLE syntax

2022-11-23 Thread Shengkai Fang
Hi, Jingsong. Thanks for your feedback! > Can we define classes at once so that the connector can be fully implemented, but we will not pass changes of the nested column. It's hard to achieve this. If a new need comes, we will add a new kind of TableChange. But I think the current proposal align

Re: [jira] [Created] (FLINK-30134) Annotate all the public classes for the delegation token framework

2022-11-23 Thread 周仁
unsubscript Gabor Somogyi (Jira) 于2022年11月22日周二 15:37写道: > Gabor Somogyi created FLINK-30134: > - > > Summary: Annotate all the public classes for the delegation > token framework > Key: FLINK-30134 > URL: https:/

Re: [DISCUSS] FLIP-273: Improve Catalog API to Support ALTER TABLE syntax

2022-11-23 Thread Jingsong Li
Thanks for the update! Looks good to me. Best, Jingsong On Thu, Nov 24, 2022 at 3:07 PM Shengkai Fang wrote: > > Hi, Jingsong. > > Thanks for your feedback! > > > Can we define classes at once so that the connector can be fully > implemented, but we will not pass changes of the nested column. >

Re: Re: [DISCUSS] FLIP-269: Properly Handling the Processing Timers on Job Termination

2022-11-23 Thread Yun Gao
Hi Piotr / Divye, Very thanks for the discussion! First IMO it seems we have reached the consensus on the high-level API: Most operators should usually have only one reasonable action to the pending timers on termination, thus we could let the operators to implement its own actions with the low-l

Re: [ANNOUNCE] New Apache Flink PMC Members - Godfrey He, Xingbo Huang

2022-11-23 Thread Yun Gao
Congratulations Godfrey and Xingbo! Best, Yun Gao -- From:Matthias Pohl Send Time:2022 Nov. 24 (Thu.) 12:25 To:dev Subject:Re: [ANNOUNCE] New Apache Flink PMC Members - Godfrey He, Xingbo Huang Congratulations to the two of you! Best

[jira] [Created] (FLINK-30186) Bump Flink version to 1.15.3

2022-11-23 Thread Jeff Yang (Jira)
Jeff Yang created FLINK-30186: - Summary: Bump Flink version to 1.15.3 Key: FLINK-30186 URL: https://issues.apache.org/jira/browse/FLINK-30186 Project: Flink Issue Type: Improvement Comp