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

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

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

[ https://issues.apache.org/jira/browse/FLINK-34071?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17842275#comment-17842275 ] Aleksandr Pilipenko commented on FLINK-34071: - [~chalixar] for exception classification I

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

[ https://issues.apache.org/jira/browse/FLINK-34071?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17842055#comment-17842055 ] Aleksandr Pilipenko commented on FLINK-34071: - We found that one of the causes of this -

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

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

[jira] [Commented] (FLINK-35115) Kinesis connector writes wrong Kinesis sequence number at stop with savepoint

[ https://issues.apache.org/jira/browse/FLINK-35115?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17838358#comment-17838358 ] Aleksandr Pilipenko commented on FLINK-35115: - snapshotState method in FlinkKinesisConsumer

[jira] [Comment Edited] (FLINK-35115) Kinesis connector writes wrong Kinesis sequence number at stop with savepoint

[ https://issues.apache.org/jira/browse/FLINK-35115?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17838358#comment-17838358 ] Aleksandr Pilipenko edited comment on FLINK-35115 at 4/17/24 7:01 PM:

[jira] [Commented] (FLINK-35115) Kinesis connector writes wrong Kinesis sequence number at stop with savepoint

[ https://issues.apache.org/jira/browse/FLINK-35115?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17838216#comment-17838216 ] Aleksandr Pilipenko commented on FLINK-35115: - Investigating further > Kinesis connector

[jira] [Commented] (FLINK-35115) Kinesis connector writes wrong Kinesis sequence number at stop with savepoint

[ https://issues.apache.org/jira/browse/FLINK-35115?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17838206#comment-17838206 ] Aleksandr Pilipenko commented on FLINK-35115: - [~vadim.vararu] thank you for information.

[jira] [Commented] (FLINK-35115) Kinesis connector writes wrong Kinesis sequence number at stop with savepoint

[ https://issues.apache.org/jira/browse/FLINK-35115?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17837562#comment-17837562 ] Aleksandr Pilipenko commented on FLINK-35115: - [~vadim.vararu] are you able to reproduce

[jira] [Commented] (FLINK-35115) Kinesis connector writes wrong Kinesis sequence number at stop with savepoint

[ https://issues.apache.org/jira/browse/FLINK-35115?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17837327#comment-17837327 ] Aleksandr Pilipenko commented on FLINK-35115: - [~dannycranmer] Agree, trying to reproduce it

[jira] [Commented] (FLINK-35073) Deadlock in LocalBufferPool when NetworkBufferPool.internalRecycleMemorySegments is called concurrently

[ https://issues.apache.org/jira/browse/FLINK-35073?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17835657#comment-17835657 ] Aleksandr Pilipenko commented on FLINK-35073: - [~jto] could you clarify which Flink version

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

[ https://issues.apache.org/jira/browse/FLINK-34892?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aleksandr Pilipenko updated FLINK-34892: Description: Build for externalized python connector code fails:

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

[ https://issues.apache.org/jira/browse/FLINK-34892?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17828922#comment-17828922 ] Aleksandr Pilipenko commented on FLINK-34892: - This issue should also be present for Kafka

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

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:

[jira] (FLINK-34490) flink-connector-kinesis not correctly supporting credential chaining

[ https://issues.apache.org/jira/browse/FLINK-34490 ] Aleksandr Pilipenko deleted comment on FLINK-34490: - was (Author: a.pilipenko): Currently, AWS connectors don't support extracting credentials from configuration files

[jira] [Comment Edited] (FLINK-34490) flink-connector-kinesis not correctly supporting credential chaining

[ https://issues.apache.org/jira/browse/FLINK-34490?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17820207#comment-17820207 ] Aleksandr Pilipenko edited comment on FLINK-34490 at 2/23/24 9:16 PM:

[jira] [Commented] (FLINK-34490) flink-connector-kinesis not correctly supporting credential chaining

[ https://issues.apache.org/jira/browse/FLINK-34490?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17820207#comment-17820207 ] Aleksandr Pilipenko commented on FLINK-34490: - Currently, AWS connectors don't support

[jira] [Commented] (FLINK-32964) KinesisStreamsSink cant renew credentials with WebIdentityTokenFileCredentialsProvider

[ https://issues.apache.org/jira/browse/FLINK-32964?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17816700#comment-17816700 ] Aleksandr Pilipenko commented on FLINK-32964: - Hi [~jank], thank you for the detailed info,

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

[ https://issues.apache.org/jira/browse/FLINK-34407?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aleksandr Pilipenko updated FLINK-34407: Affects Version/s: (was: aws-connector-3.0.0) > Flaky tests causing workflow

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

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

[jira] [Commented] (FLINK-34260) Update flink-connector-aws to be compatible with updated SinkV2 interfaces

[ https://issues.apache.org/jira/browse/FLINK-34260?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17813126#comment-17813126 ] Aleksandr Pilipenko commented on FLINK-34260: - Hey [~jiabao.sun], thank you for info, it was

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

[ https://issues.apache.org/jira/browse/FLINK-34267?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aleksandr Pilipenko updated FLINK-34267: Component/s: API / Python > Python connector test fails when running on MacBook

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

[ https://issues.apache.org/jira/browse/FLINK-34267?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aleksandr Pilipenko updated FLINK-34267: Component/s: Build System / CI > Python connector test fails when running on

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

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] [Updated] (FLINK-34071) Deadlock in AWS Kinesis Data Streams AsyncSink connector

[ https://issues.apache.org/jira/browse/FLINK-34071?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aleksandr Pilipenko updated FLINK-34071: Description: Sink operator hangs while flushing records, similarly to

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

[ https://issues.apache.org/jira/browse/FLINK-34071?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aleksandr Pilipenko updated FLINK-34071: Description: Sink operator hangs while flushing records, similarly to

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

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] [Comment Edited] (FLINK-33589) Fix broken documentation page for Kinesis connector

[ https://issues.apache.org/jira/browse/FLINK-33589?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17787897#comment-17787897 ] Aleksandr Pilipenko edited comment on FLINK-33589 at 11/20/23 9:22 AM:

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

[ https://issues.apache.org/jira/browse/FLINK-33589?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17787897#comment-17787897 ] Aleksandr Pilipenko commented on FLINK-33589: - [~martijnvisser] it's the same with your link

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

[ https://issues.apache.org/jira/browse/FLINK-33589?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17787891#comment-17787891 ] Aleksandr Pilipenko commented on FLINK-33589: - [~martijnvisser]  Cassandra connector does

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

[ https://issues.apache.org/jira/browse/FLINK-33589?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17787353#comment-17787353 ] Aleksandr Pilipenko commented on FLINK-33589: - cc [~martijnvisser] > Fix broken

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

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

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] [Commented] (FLINK-32964) KinesisStreamsSink cant renew credentials with WebIdentityTokenFileCredentialsProvider

[ https://issues.apache.org/jira/browse/FLINK-32964?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17765095#comment-17765095 ] Aleksandr Pilipenko commented on FLINK-32964: - Hi [~pbenaoun], I was not able to reproduce

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

[ https://issues.apache.org/jira/browse/FLINK-32962?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17763326#comment-17763326 ] Aleksandr Pilipenko commented on FLINK-32962: - Fix for 1.18 has been merged, added 

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

[ https://issues.apache.org/jira/browse/FLINK-32962?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17761797#comment-17761797 ] Aleksandr Pilipenko commented on FLINK-32962: - cc [~dianfu], [~hxbks2ks] > Failure to

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

[ https://issues.apache.org/jira/browse/FLINK-32962?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aleksandr Pilipenko updated FLINK-32962: Affects Version/s: 1.18.0 > Failure to install python dependencies from

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

[ https://issues.apache.org/jira/browse/FLINK-32962?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aleksandr Pilipenko updated FLINK-32962: Description: We have encountered an issue when Flink fails to install python

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

[ https://issues.apache.org/jira/browse/FLINK-32962?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aleksandr Pilipenko updated FLINK-32962: Description: We have encountered an issue when Flink fails to install python

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

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

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+

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] [Comment Edited] (FLINK-31804) ITCase MiniCluster test architecture rule should accept MiniClusterTestEnvironment

[ https://issues.apache.org/jira/browse/FLINK-31804?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17723543#comment-17723543 ] Aleksandr Pilipenko edited comment on FLINK-31804 at 5/17/23 5:09 PM:

[jira] [Commented] (FLINK-31804) ITCase MiniCluster test architecture rule should accept MiniClusterTestEnvironment

[ https://issues.apache.org/jira/browse/FLINK-31804?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17723543#comment-17723543 ] Aleksandr Pilipenko commented on FLINK-31804: - Change in error message causing build

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

[ https://issues.apache.org/jira/browse/FLINK-31457?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17700680#comment-17700680 ] Aleksandr Pilipenko commented on FLINK-31457: - [~JunRuiLi], thank you for your response.

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

[ https://issues.apache.org/jira/browse/FLINK-31458?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aleksandr Pilipenko closed FLINK-31458. --- Resolution: Duplicate > Support waiting for required resources in DefaultScheduler

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

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

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] [Updated] (FLINK-30806) Bump protobuf-java dependency version for aws connectors

[ https://issues.apache.org/jira/browse/FLINK-30806?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aleksandr Pilipenko updated FLINK-30806: Description: Update protobuf-java dependency version to at least 3.19.6 to match

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

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

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

Aleksandr Pilipenko created FLINK-29496: --- Summary: Unable to configure STS endpoint when using ASSUME_ROLE credential provider in Kinesis connector Key: FLINK-29496 URL: