[DISCUSS] Flink upgrade compatibility page not updated for Flink 1.19

2024-05-21 Thread Aleksandr Pilipenko
Hi all, Current version of documentation missing savepoint compatibility data for Flink 1.19 [1]. I have created a ticket [2] and PRs to address this, but wanted to clarify if there any changes that make savepoint compatibility different from previous releases? I did not find any changes related

[jira] [Created] (FLINK-35383) Update compatibility matrix to include 1.19 release

2024-05-16 Thread Aleksandr Pilipenko (Jira)
Aleksandr Pilipenko created FLINK-35383: --- Summary: Update compatibility matrix to include 1.19 release Key: FLINK-35383 URL: https://issues.apache.org/jira/browse/FLINK-35383 Project: Flink

Re: [VOTE] FLIP-451: Introduce timeout configuration to AsyncSink

2024-05-13 Thread Aleksandr Pilipenko
Thanks for driving this! +1 (non-binding) Thanks, Aleksandr On Mon, 13 May 2024 at 14:08, wrote: > Thanks Ahmed! > > +1 non binding > On May 13, 2024 at 12:40 +0200, Jeyhun Karimov , > wrote: > > Thanks for driving this Ahmed. > > > > +1 (non-binding) > > > > Regards, > > Jeyhun > > > > On

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

2024-05-10 Thread Aleksandr Pilipenko
Thanks for driving this! +1 (non-binding) Thanks, Aleksandr On Fri, 10 May 2024 at 10:58, Rui Fan <1996fan...@gmail.com> wrote: > Thanks for driving this proposal! > > +1(binding) > > Best, > Rui > > On Fri, May 10, 2024 at 9:50 AM Yuepeng Pan wrote: > > > Hi, Boto. > > > > +1 (non-binding).

Re: [VOTE] FLIP-447: Upgrade FRocksDB from 6.20.3 to 8.10.0

2024-05-09 Thread Aleksandr Pilipenko
Thanks for driving this! +1 (non-binding) Thanks, Aleksandr On Thu, 9 May 2024 at 12:21, Ahmed Hamdy wrote: > Thanks for the effort and the data provided. > > +1 (non-binding) > Best Regards > Ahmed Hamdy > > > On Thu, 9 May 2024 at 08:20, Keith Lee > wrote: > > > +1 (non-binding) > > > >

Re: [DISCUSS] FLIP-444: Native file copy support

2024-05-02 Thread Aleksandr Pilipenko
Hi Piotr, Thanks for the proposal. How adding a s5cmd will affect memory footprint? Since this is a native binary, memory consumption will not be controlled by JVM or Flink. Thanks, Aleksandr On Thu, 2 May 2024 at 11:12, Hong Liang wrote: > Hi Piotr, > > Thanks for the FLIP! Nice to see work

[jira] [Created] (FLINK-35269) Fix logging level for errors in AWS connector sinks

2024-04-29 Thread Aleksandr Pilipenko (Jira)
Aleksandr Pilipenko created FLINK-35269: --- Summary: Fix logging level for errors in AWS connector sinks Key: FLINK-35269 URL: https://issues.apache.org/jira/browse/FLINK-35269 Project: Flink

Re: [VOTE] Release flink-connector-kafka v3.2.0, release candidate #1

2024-04-28 Thread Aleksandr Pilipenko
+1 (non-binding) - Validated checksum - Verified signature - Checked that no binaries exist in the source archive - Build source - Verified web PR Thanks, Aleksandr On Sun, 28 Apr 2024 at 11:35, Hang Ruan wrote: > +1 (non-binding) > > - Validated checksum hash > - Verified signature > -

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

2024-04-28 Thread Aleksandr Pilipenko
+1 (non-binding) - Verified checksums - Verified signatures - Checked that no binaries exist in the source archive - Reviewed Web PR - Built source Thanks, Aleksandr On Mon, 22 Apr 2024 at 09:31, Ahmed Hamdy wrote: > Thanks Danny, > +1 (non-binding) > > - Verified Checksums > - Verified

Re: [VOTE] Release flink-connector-aws v4.3.0, release candidate #1

2024-04-17 Thread Aleksandr Pilipenko
Hi Danny, There is a blocker bug reported in Kinesis connector [1] We should pause the release until it is resolved. [1] https://issues.apache.org/jira/browse/FLINK-35115 Thanks, Aleksandr

Re: [Vote] FLIP-438: Amazon SQS Sink Connector

2024-04-15 Thread Aleksandr Pilipenko
+1 (non-binding), Best, Aleksandr

Re: [VOTE] FLIP-399: Flink Connector Doris

2024-04-15 Thread Aleksandr Pilipenko
+1 (non-binding), Best, Aleksandr On Mon, 15 Apr 2024 at 03:03, Yanquan Lv wrote: > +1 (non-binding), thanks for it. > > wudi <676366...@qq.com.invalid> 于2024年4月9日周二 10:48写道: > > > Hi devs, > > > > I would like to start a vote about FLIP-399 [1]. The FLIP is about > > contributing the Flink

Re: [DISCUSS] FLIP-438: Amazon SQS Sink Connector

2024-04-12 Thread Aleksandr Pilipenko
Hi Priya, Thank you for the FLIP, SQS connector will be a great addition for AWS connectors. I agree with Ahmed, it would be better to leave implementation details of the sink out of the FLIP and focus on how users of this connector will be interacting with it, mainly available configuration

Re: [ANNOUNCE] New Apache Flink PMC Member - Lincoln Lee

2024-04-12 Thread Aleksandr Pilipenko
Congratulations, Lincoln! Best Regards Aleksandr

Re: [ANNOUNCE] New Apache Flink PMC Member - Jing Ge

2024-04-12 Thread Aleksandr Pilipenko
Congratulations, Jing! Best Regards, Aleksandr

Re: [DISCUSS] Migrate Kinesis Table API source to KDS client

2024-03-24 Thread Aleksandr Pilipenko
with an unstable API. Best regards, Aleksandr Pilipenko On Sun, 24 Mar 2024 at 15:19, Ahmed Hamdy wrote: > Hi devs, > With the delivery of FLINK-31813 > <https://issues.apache.org/jira/browse/FLINK-31813>[1] that offers a new > Datastream Kinesis Streams source paving the way to deprecat

[jira] [Created] (FLINK-34892) Nightly AWS connectors build fails on running python tests

2024-03-20 Thread Aleksandr Pilipenko (Jira)
Aleksandr Pilipenko created FLINK-34892: --- Summary: Nightly AWS connectors build fails on running python tests Key: FLINK-34892 URL: https://issues.apache.org/jira/browse/FLINK-34892 Project

Re: Flink kinesis connector v4.2.0-1.18 has issue when consuming from EFO consumer

2024-02-29 Thread Aleksandr Pilipenko
ccess(BaseAsyncClientHandler.java: > 291) ~[?:?] > at > > org.apache.flink.kinesis.shaded.software.amazon.awssdk.core.internal.handler.BaseAsyncClientHandler.execute(BaseAsyncClientHandler.java: > 91) ~[?:?] > at > > org.apache.flink.kinesis.shaded.software.amazon.awssdk.awscore.client

Re: Flink kinesis connector v4.2.0-1.18 has issue when consuming from EFO consumer

2024-02-28 Thread Aleksandr Pilipenko
Hi, Could you please provide more information on the error you are observing? Attached file does not have anything related to Kinesis or any errors. Best, Aleksandr On Wed, 28 Feb 2024 at 02:28, Xiaolong Wang wrote: > Hi, > > I used the flink-connector-kinesis (4.0.2-1.18) to consume from

[jira] [Created] (FLINK-34407) Flaky tests causing workflow timeout

2024-02-07 Thread Aleksandr Pilipenko (Jira)
Aleksandr Pilipenko created FLINK-34407: --- Summary: Flaky tests causing workflow timeout Key: FLINK-34407 URL: https://issues.apache.org/jira/browse/FLINK-34407 Project: Flink Issue

Re: [VOTE] FLIP-418: Show data skew score on Flink Dashboard

2024-01-30 Thread Aleksandr Pilipenko
Thanks for the FLIP! +1 (non-binding) Best, Aleksandr On Mon, 29 Jan 2024 at 10:11, Kartoglu, Emre wrote: > Hello, > > I'd like to call votes on FLIP-418: Show data skew score on Flink > Dashboard. > > FLIP: >

[jira] [Created] (FLINK-34267) Python connector test fails when running on MacBook with m1 processor

2024-01-29 Thread Aleksandr Pilipenko (Jira)
Aleksandr Pilipenko created FLINK-34267: --- Summary: Python connector test fails when running on MacBook with m1 processor Key: FLINK-34267 URL: https://issues.apache.org/jira/browse/FLINK-34267

[jira] [Created] (FLINK-34071) Deadlock in AWS Kinesis Data Streams AsyncSink connector

2024-01-13 Thread Aleksandr Pilipenko (Jira)
Aleksandr Pilipenko created FLINK-34071: --- Summary: Deadlock in AWS Kinesis Data Streams AsyncSink connector Key: FLINK-34071 URL: https://issues.apache.org/jira/browse/FLINK-34071 Project: Flink

[jira] [Created] (FLINK-33589) Fix broken documentation page for Kinesis connector

2023-11-17 Thread Aleksandr Pilipenko (Jira)
Aleksandr Pilipenko created FLINK-33589: --- Summary: Fix broken documentation page for Kinesis connector Key: FLINK-33589 URL: https://issues.apache.org/jira/browse/FLINK-33589 Project: Flink

[jira] [Created] (FLINK-33176) Kinesis source throws NullPointerException in Table API on ignored parsing errors

2023-10-02 Thread Aleksandr Pilipenko (Jira)
Aleksandr Pilipenko created FLINK-33176: --- Summary: Kinesis source throws NullPointerException in Table API on ignored parsing errors Key: FLINK-33176 URL: https://issues.apache.org/jira/browse/FLINK-33176

[jira] [Created] (FLINK-32962) Failure to install python dependencies from requirements file

2023-08-25 Thread Aleksandr Pilipenko (Jira)
Aleksandr Pilipenko created FLINK-32962: --- Summary: Failure to install python dependencies from requirements file Key: FLINK-32962 URL: https://issues.apache.org/jira/browse/FLINK-32962 Project

[jira] [Created] (FLINK-32500) Update dependency versions for AWS connectors package

2023-06-30 Thread Aleksandr Pilipenko (Jira)
Aleksandr Pilipenko created FLINK-32500: --- Summary: Update dependency versions for AWS connectors package Key: FLINK-32500 URL: https://issues.apache.org/jira/browse/FLINK-32500 Project: Flink

[jira] [Created] (FLINK-32399) Fix flink-sql-connector-kinesis build for maven 3.8.6+

2023-06-20 Thread Aleksandr Pilipenko (Jira)
Aleksandr Pilipenko created FLINK-32399: --- Summary: Fix flink-sql-connector-kinesis build for maven 3.8.6+ Key: FLINK-32399 URL: https://issues.apache.org/jira/browse/FLINK-32399 Project: Flink

[jira] [Created] (FLINK-31458) Support waiting for required resources in DefaultScheduler during job restart

2023-03-14 Thread Aleksandr Pilipenko (Jira)
Aleksandr Pilipenko created FLINK-31458: --- Summary: Support waiting for required resources in DefaultScheduler during job restart Key: FLINK-31458 URL: https://issues.apache.org/jira/browse/FLINK-31458

[jira] [Created] (FLINK-31457) Support waiting for required resources in DefaultScheduler during job restart

2023-03-14 Thread Aleksandr Pilipenko (Jira)
Aleksandr Pilipenko created FLINK-31457: --- Summary: Support waiting for required resources in DefaultScheduler during job restart Key: FLINK-31457 URL: https://issues.apache.org/jira/browse/FLINK-31457

[jira] [Created] (FLINK-30806) Bump protobuf-java dependency version for aws connectors

2023-01-27 Thread Aleksandr Pilipenko (Jira)
Aleksandr Pilipenko created FLINK-30806: --- Summary: Bump protobuf-java dependency version for aws connectors Key: FLINK-30806 URL: https://issues.apache.org/jira/browse/FLINK-30806 Project: Flink

[jira] [Created] (FLINK-30762) Add nightly builds for AWS connectors repo

2023-01-20 Thread Aleksandr Pilipenko (Jira)
Aleksandr Pilipenko created FLINK-30762: --- Summary: Add nightly builds for AWS connectors repo Key: FLINK-30762 URL: https://issues.apache.org/jira/browse/FLINK-30762 Project: Flink

[jira] [Created] (FLINK-29496) Unable to configure STS endpoint when using ASSUME_ROLE credential provider in Kinesis connector

2022-10-03 Thread Aleksandr Pilipenko (Jira)
Aleksandr Pilipenko created FLINK-29496: --- Summary: Unable to configure STS endpoint when using ASSUME_ROLE credential provider in Kinesis connector Key: FLINK-29496 URL: https://issues.apache.org/jira