[jira] [Closed] (FLINK-19226) [Kinesis] [EFO] Connector reaches default max attempts for describeStream and describeStreamConsumer when parallelism is high

2020-09-15 Thread Hong Liang Teoh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19226?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hong Liang Teoh closed FLINK-19226. --- Resolution: Abandoned > [Kinesis] [EFO] Connector reaches default max attempts for

[jira] [Created] (FLINK-19226) [Kinesis] [EFO] Connector reaches default max attempts for describeStream and describeStreamConsumer when parallelism is high

2020-09-14 Thread Hong Liang Teoh (Jira)
Hong Liang Teoh created FLINK-19226: --- Summary: [Kinesis] [EFO] Connector reaches default max attempts for describeStream and describeStreamConsumer when parallelism is high Key: FLINK-19226 URL:

[jira] [Assigned] (FLINK-33021) AWS nightly builds fails on architecture tests

2023-09-05 Thread Hong Liang Teoh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33021?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hong Liang Teoh reassigned FLINK-33021: --- Assignee: Hong Liang Teoh > AWS nightly builds fails on architecture tests >

[jira] [Resolved] (FLINK-33021) AWS nightly builds fails on architecture tests

2023-09-05 Thread Hong Liang Teoh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33021?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hong Liang Teoh resolved FLINK-33021. - Resolution: Fixed > AWS nightly builds fails on architecture tests >

[jira] [Commented] (FLINK-33021) AWS nightly builds fails on architecture tests

2023-09-05 Thread Hong Liang Teoh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33021?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17762040#comment-17762040 ] Hong Liang Teoh commented on FLINK-33021: - Latest nightly build has passed. Will resolve this

[jira] (FLINK-33021) AWS nightly builds fails on architecture tests

2023-09-05 Thread Hong Liang Teoh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33021 ] Hong Liang Teoh deleted comment on FLINK-33021: - was (Author: hong): Triggering the nightly build now.  https://github.com/apache/flink-connector-aws/actions/runs/6067488560 > AWS

[jira] [Commented] (FLINK-28513) Flink Table API CSV streaming sink throws SerializedThrowable exception

2023-09-05 Thread Hong Liang Teoh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28513?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17762039#comment-17762039 ] Hong Liang Teoh commented on FLINK-28513: - merged commit 

[jira] [Commented] (FLINK-33021) AWS nightly builds fails on architecture tests

2023-09-05 Thread Hong Liang Teoh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33021?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17762042#comment-17762042 ] Hong Liang Teoh commented on FLINK-33021: - merged commit 

[jira] [Commented] (FLINK-33021) AWS nightly builds fails on architecture tests

2023-09-04 Thread Hong Liang Teoh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33021?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17761860#comment-17761860 ] Hong Liang Teoh commented on FLINK-33021: - Ah. I only saw this now :( But I'll link the PR for

[jira] [Commented] (FLINK-33021) AWS nightly builds fails on architecture tests

2023-09-04 Thread Hong Liang Teoh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33021?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17761861#comment-17761861 ] Hong Liang Teoh commented on FLINK-33021: - Triggering the nightly build now. 

[jira] [Updated] (FLINK-33021) AWS nightly builds fails on architecture tests

2023-09-04 Thread Hong Liang Teoh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33021?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hong Liang Teoh updated FLINK-33021: Fix Version/s: aws-connector-4.2.0 > AWS nightly builds fails on architecture tests >

[jira] [Created] (FLINK-33073) Implement end-to-end tests for the Kinesis Streams Sink

2023-09-11 Thread Hong Liang Teoh (Jira)
Hong Liang Teoh created FLINK-33073: --- Summary: Implement end-to-end tests for the Kinesis Streams Sink Key: FLINK-33073 URL: https://issues.apache.org/jira/browse/FLINK-33073 Project: Flink

[jira] [Updated] (FLINK-33072) Implement end-to-end tests for AWS Kinesis Connectors

2023-09-11 Thread Hong Liang Teoh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33072?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hong Liang Teoh updated FLINK-33072: Description: *What* We want to implement end-to-end tests that target real Kinesis Data

[jira] [Assigned] (FLINK-33073) Implement end-to-end tests for the Kinesis Streams Sink

2023-09-11 Thread Hong Liang Teoh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33073?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hong Liang Teoh reassigned FLINK-33073: --- Assignee: Hong Liang Teoh > Implement end-to-end tests for the Kinesis Streams

[jira] [Created] (FLINK-33072) Implement end-to-end tests for AWS Kinesis Connectors

2023-09-11 Thread Hong Liang Teoh (Jira)
Hong Liang Teoh created FLINK-33072: --- Summary: Implement end-to-end tests for AWS Kinesis Connectors Key: FLINK-33072 URL: https://issues.apache.org/jira/browse/FLINK-33072 Project: Flink

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

2023-09-07 Thread Hong Liang Teoh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32962?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17762805#comment-17762805 ] Hong Liang Teoh commented on FLINK-32962: - merged commit

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

2023-09-07 Thread Hong Liang Teoh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32962?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17762807#comment-17762807 ] Hong Liang Teoh commented on FLINK-32962: - [~a.pilipenko]  should we also backport this to Flink

[jira] [Resolved] (FLINK-28513) Flink Table API CSV streaming sink throws SerializedThrowable exception

2023-09-04 Thread Hong Liang Teoh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28513?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hong Liang Teoh resolved FLINK-28513. - Fix Version/s: 1.19.0 Resolution: Fixed > Flink Table API CSV streaming sink

[jira] [Commented] (FLINK-33021) AWS nightly builds fails on architecture tests

2023-09-04 Thread Hong Liang Teoh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33021?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17761740#comment-17761740 ] Hong Liang Teoh commented on FLINK-33021: - This has been fixed here!  > AWS nightly builds

[jira] [Comment Edited] (FLINK-33021) AWS nightly builds fails on architecture tests

2023-09-04 Thread Hong Liang Teoh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33021?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17761740#comment-17761740 ] Hong Liang Teoh edited comment on FLINK-33021 at 9/4/23 9:01 AM: - This

[jira] [Commented] (FLINK-28513) Flink Table API CSV streaming sink throws SerializedThrowable exception

2023-09-04 Thread Hong Liang Teoh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28513?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17761787#comment-17761787 ] Hong Liang Teoh commented on FLINK-28513: - [~samrat007]  Could we backport this bugfix to Flink

[jira] [Commented] (FLINK-28513) Flink Table API CSV streaming sink throws SerializedThrowable exception

2023-09-04 Thread Hong Liang Teoh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28513?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17761785#comment-17761785 ] Hong Liang Teoh commented on FLINK-28513: -  merged commit 

[jira] [Commented] (FLINK-28513) Flink Table API CSV streaming sink throws SerializedThrowable exception

2023-09-04 Thread Hong Liang Teoh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28513?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17761855#comment-17761855 ] Hong Liang Teoh commented on FLINK-28513: - merged commit 

[jira] [Commented] (FLINK-28513) Flink Table API CSV streaming sink throws SerializedThrowable exception

2023-09-04 Thread Hong Liang Teoh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28513?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17761856#comment-17761856 ] Hong Liang Teoh commented on FLINK-28513: - > I dont have access to update the fix version .

[jira] [Updated] (FLINK-28513) Flink Table API CSV streaming sink throws SerializedThrowable exception

2023-09-04 Thread Hong Liang Teoh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28513?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hong Liang Teoh updated FLINK-28513: Fix Version/s: 1.18.0 1.17.2 > Flink Table API CSV streaming sink

[jira] [Comment Edited] (FLINK-28513) Flink Table API CSV streaming sink throws SerializedThrowable exception

2023-09-04 Thread Hong Liang Teoh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28513?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17761856#comment-17761856 ] Hong Liang Teoh edited comment on FLINK-28513 at 9/4/23 3:17 PM: -

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

2023-09-08 Thread Hong Liang Teoh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32962?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17763052#comment-17763052 ] Hong Liang Teoh commented on FLINK-32962: - merged commit 

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

2023-09-08 Thread Hong Liang Teoh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32962?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hong Liang Teoh updated FLINK-32962: Fix Version/s: 1.18.0 1.19.0 > Failure to install python dependencies

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

2023-09-08 Thread Hong Liang Teoh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32962?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hong Liang Teoh updated FLINK-32962: Fix Version/s: 1.17.2 > Failure to install python dependencies from requirements file >

[jira] [Commented] (FLINK-33194) AWS Connector should directly depend on 3rd-party libs instead of flink-shaded repo

2023-10-27 Thread Hong Liang Teoh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33194?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17780273#comment-17780273 ] Hong Liang Teoh commented on FLINK-33194: - merged commit

[jira] [Resolved] (FLINK-33194) AWS Connector should directly depend on 3rd-party libs instead of flink-shaded repo

2023-10-27 Thread Hong Liang Teoh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33194?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hong Liang Teoh resolved FLINK-33194. - Resolution: Fixed > AWS Connector should directly depend on 3rd-party libs instead of

[jira] [Assigned] (FLINK-33194) AWS Connector should directly depend on 3rd-party libs instead of flink-shaded repo

2023-10-27 Thread Hong Liang Teoh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33194?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hong Liang Teoh reassigned FLINK-33194: --- Assignee: Jiabao Sun > AWS Connector should directly depend on 3rd-party libs

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

2023-09-19 Thread Hong Liang Teoh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32962?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17766736#comment-17766736 ] Hong Liang Teoh commented on FLINK-32962: - merged commit 

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

2023-09-19 Thread Hong Liang Teoh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32962?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hong Liang Teoh resolved FLINK-32962. - Resolution: Fixed > Failure to install python dependencies from requirements file >

[jira] [Assigned] (FLINK-33137) FLIP-312: Prometheus Sink Connector

2023-09-25 Thread Hong Liang Teoh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33137?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hong Liang Teoh reassigned FLINK-33137: --- Assignee: Lorenzo Nicora > FLIP-312: Prometheus Sink Connector >

[jira] [Created] (FLINK-33167) Run IT tests against Kinesalite if AWS credentials are not present

2023-09-28 Thread Hong Liang Teoh (Jira)
Hong Liang Teoh created FLINK-33167: --- Summary: Run IT tests against Kinesalite if AWS credentials are not present Key: FLINK-33167 URL: https://issues.apache.org/jira/browse/FLINK-33167 Project:

[jira] [Commented] (FLINK-33175) Nightly builds from S3 are not available for download, breaking all connector tests

2023-10-09 Thread Hong Liang Teoh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33175?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17773294#comment-17773294 ] Hong Liang Teoh commented on FLINK-33175: - Verified the flink-connector-aws one succeeds as

[jira] [Assigned] (FLINK-33138) Prometheus Connector Sink - DataStream API implementation

2023-10-09 Thread Hong Liang Teoh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33138?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hong Liang Teoh reassigned FLINK-33138: --- Assignee: Lorenzo Nicora > Prometheus Connector Sink - DataStream API

[jira] [Resolved] (FLINK-33141) Promentheus Sink Connector - Amazon Managed Prometheus Request Signer

2023-10-09 Thread Hong Liang Teoh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33141?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hong Liang Teoh resolved FLINK-33141. - Resolution: Implemented Resolved by https://issues.apache.org/jira/browse/FLINK-33138

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

2023-10-12 Thread Hong Liang Teoh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32399?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17774539#comment-17774539 ] Hong Liang Teoh commented on FLINK-32399: - merged commit

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

2023-10-12 Thread Hong Liang Teoh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32399?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hong Liang Teoh resolved FLINK-32399. - Resolution: Fixed > Fix flink-sql-connector-kinesis build for maven 3.8.6+ >

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

2023-10-12 Thread Hong Liang Teoh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32399?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hong Liang Teoh reassigned FLINK-32399: --- Assignee: Aleksandr Pilipenko > Fix flink-sql-connector-kinesis build for maven

[jira] [Created] (FLINK-33259) flink-connector-aws should use/extend the common connector workflow

2023-10-12 Thread Hong Liang Teoh (Jira)
Hong Liang Teoh created FLINK-33259: --- Summary: flink-connector-aws should use/extend the common connector workflow Key: FLINK-33259 URL: https://issues.apache.org/jira/browse/FLINK-33259 Project:

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

2023-10-12 Thread Hong Liang Teoh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32399?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17774628#comment-17774628 ] Hong Liang Teoh commented on FLINK-32399: - Ah, that's a good call. We will need to make some

[jira] [Created] (FLINK-28487) Introduce configurable RateLimitingStrategy for Async Sink

2022-07-11 Thread Hong Liang Teoh (Jira)
Hong Liang Teoh created FLINK-28487: --- Summary: Introduce configurable RateLimitingStrategy for Async Sink Key: FLINK-28487 URL: https://issues.apache.org/jira/browse/FLINK-28487 Project: Flink

[jira] [Created] (FLINK-29683) Introduce config parser for AWS BackoffStrategy

2022-10-18 Thread Hong Liang Teoh (Jira)
Hong Liang Teoh created FLINK-29683: --- Summary: Introduce config parser for AWS BackoffStrategy Key: FLINK-29683 URL: https://issues.apache.org/jira/browse/FLINK-29683 Project: Flink Issue

[jira] [Updated] (FLINK-28487) Introduce configurable RateLimitingStrategy for Async Sink

2022-09-14 Thread Hong Liang Teoh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28487?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hong Liang Teoh updated FLINK-28487: Release Note: Supports configurable RateLimitingStrategy for the AsyncSinkWriter. This

[jira] [Comment Edited] (FLINK-28487) Introduce configurable RateLimitingStrategy for Async Sink

2022-09-14 Thread Hong Liang Teoh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28487?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17603895#comment-17603895 ] Hong Liang Teoh edited comment on FLINK-28487 at 9/14/22 7:44 AM: -- Sure

[jira] [Commented] (FLINK-28487) Introduce configurable RateLimitingStrategy for Async Sink

2022-09-14 Thread Hong Liang Teoh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28487?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17603895#comment-17603895 ] Hong Liang Teoh commented on FLINK-28487: - Sure, where do I write the release notes? >

[jira] [Comment Edited] (FLINK-28487) Introduce configurable RateLimitingStrategy for Async Sink

2022-09-14 Thread Hong Liang Teoh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28487?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17603895#comment-17603895 ] Hong Liang Teoh edited comment on FLINK-28487 at 9/14/22 6:02 AM: -- Sure

[jira] [Updated] (FLINK-29395) [Kinesis][EFO] Issue using EFO consumer at timestamp with empty shard

2022-09-22 Thread Hong Liang Teoh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29395?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hong Liang Teoh updated FLINK-29395: Fix Version/s: 1.16.0 (was: 1.12.0) Affects Version/s:

[jira] [Created] (FLINK-29395) [Kinesis][EFO] Issue using EFO consumer at timestamp with empty shard

2022-09-22 Thread Hong Liang Teoh (Jira)
Hong Liang Teoh created FLINK-29395: --- Summary: [Kinesis][EFO] Issue using EFO consumer at timestamp with empty shard Key: FLINK-29395 URL: https://issues.apache.org/jira/browse/FLINK-29395 Project:

[jira] [Commented] (FLINK-29365) Millisecond behind latest jumps after Flink 1.15.2 upgrade

2022-09-25 Thread Hong Liang Teoh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29365?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17609254#comment-17609254 ] Hong Liang Teoh commented on FLINK-29365: - Hi [~wilsonwu], Thanks for reporting this. Indeed,

[jira] [Commented] (FLINK-29365) Millisecond behind latest jumps after Flink 1.15.2 upgrade

2022-10-05 Thread Hong Liang Teoh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29365?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17612880#comment-17612880 ] Hong Liang Teoh commented on FLINK-29365: - Thanks for the logs, [~wilsonwu]! The logs are a

[jira] [Updated] (FLINK-29395) [Kinesis][EFO] Issue using EFO consumer at timestamp with empty shard

2022-10-10 Thread Hong Liang Teoh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29395?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hong Liang Teoh updated FLINK-29395: Description: *Background* The consumer fails when an EFO record publisher uses a

[jira] [Updated] (FLINK-29395) [Kinesis][EFO] Issue using EFO consumer at timestamp with empty shard

2022-10-10 Thread Hong Liang Teoh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29395?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hong Liang Teoh updated FLINK-29395: Description: *Background* The consumer fails when an EFO record publisher uses a

[jira] [Updated] (FLINK-29395) [Kinesis][EFO] Issue using EFO consumer at timestamp with empty shard

2022-10-10 Thread Hong Liang Teoh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29395?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hong Liang Teoh updated FLINK-29395: Description: *Background* The consumer fails when an EFO record publisher uses a

[jira] [Updated] (FLINK-29395) [Kinesis][EFO] Issue using EFO consumer at timestamp with empty shard

2022-10-10 Thread Hong Liang Teoh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29395?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hong Liang Teoh updated FLINK-29395: Description: *Background* The consumer fails when an EFO record publisher uses a

[jira] [Updated] (FLINK-29395) [Kinesis][EFO] Issue using EFO consumer at timestamp with empty shard

2022-10-10 Thread Hong Liang Teoh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29395?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hong Liang Teoh updated FLINK-29395: Description: *Background* The consumer fails when an EFO record publisher uses a

[jira] [Updated] (FLINK-29395) [Kinesis][EFO] Issue using EFO consumer at timestamp with empty shard

2022-10-10 Thread Hong Liang Teoh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29395?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hong Liang Teoh updated FLINK-29395: Description: *Background* The consumer fails when an EFO record publisher uses a

[jira] [Updated] (FLINK-29395) [Kinesis][EFO] Issue using EFO consumer at timestamp with empty shard

2022-10-10 Thread Hong Liang Teoh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29395?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hong Liang Teoh updated FLINK-29395: Description: *Background* The consumer fails when an EFO record publisher uses a

[jira] [Created] (FLINK-29574) Upgrade software.amazon.glue:schema-registry-common and software.amazon.glue:schema-registry-serde dependency from 1.1.8 to 1.1.14

2022-10-10 Thread Hong Liang Teoh (Jira)
Hong Liang Teoh created FLINK-29574: --- Summary: Upgrade software.amazon.glue:schema-registry-common and software.amazon.glue:schema-registry-serde dependency from 1.1.8 to 1.1.14 Key: FLINK-29574 URL:

[jira] [Created] (FLINK-28978) [aws][connectors] Kinesis connector doesn't work for new AWS regions

2022-08-15 Thread Hong Liang Teoh (Jira)
Hong Liang Teoh created FLINK-28978: --- Summary: [aws][connectors] Kinesis connector doesn't work for new AWS regions Key: FLINK-28978 URL: https://issues.apache.org/jira/browse/FLINK-28978 Project:

[jira] [Created] (FLINK-30092) Improve Table API experience for Flink DOUBLE type

2022-11-18 Thread Hong Liang Teoh (Jira)
Hong Liang Teoh created FLINK-30092: --- Summary: Improve Table API experience for Flink DOUBLE type Key: FLINK-30092 URL: https://issues.apache.org/jira/browse/FLINK-30092 Project: Flink

[jira] [Created] (FLINK-30156) [FLIP-242] Blogpost about the customisable RateLimitingStrategy in the AsyncSinkBase

2022-11-22 Thread Hong Liang Teoh (Jira)
Hong Liang Teoh created FLINK-30156: --- Summary: [FLIP-242] Blogpost about the customisable RateLimitingStrategy in the AsyncSinkBase Key: FLINK-30156 URL: https://issues.apache.org/jira/browse/FLINK-30156

[jira] [Updated] (FLINK-30096) Rename DynamoDB config destinationTableName to tableName

2022-11-19 Thread Hong Liang Teoh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30096?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hong Liang Teoh updated FLINK-30096: Component/s: Connectors / DynamoDB Affects Version/s: aws-connector-2.0.0 >

[jira] [Created] (FLINK-30096) Rename DynamoDB config destinationTableName to tableName

2022-11-19 Thread Hong Liang Teoh (Jira)
Hong Liang Teoh created FLINK-30096: --- Summary: Rename DynamoDB config destinationTableName to tableName Key: FLINK-30096 URL: https://issues.apache.org/jira/browse/FLINK-30096 Project: Flink

[jira] [Updated] (FLINK-30092) Improve Table API experience for Flink DOUBLE type

2022-11-19 Thread Hong Liang Teoh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30092?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hong Liang Teoh updated FLINK-30092: Description: Currently, the DynamoDB sink's Table API allows users to input records with

[jira] [Commented] (FLINK-30092) Improve Table API experience for Flink DOUBLE type

2022-11-19 Thread Hong Liang Teoh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30092?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17636145#comment-17636145 ] Hong Liang Teoh commented on FLINK-30092: - [~martijnvisser], indeed! Thanks for pointing that

[jira] [Created] (FLINK-30098) Update DynamoDb Sink unit tests to JUnit 5

2022-11-19 Thread Hong Liang Teoh (Jira)
Hong Liang Teoh created FLINK-30098: --- Summary: Update DynamoDb Sink unit tests to JUnit 5 Key: FLINK-30098 URL: https://issues.apache.org/jira/browse/FLINK-30098 Project: Flink Issue Type:

[jira] [Updated] (FLINK-30098) Update DynamoDb Sink unit tests to JUnit 5

2022-11-19 Thread Hong Liang Teoh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30098?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hong Liang Teoh updated FLINK-30098: Description: Use JUnit 5 in all unit tests for dynamoDB sink.   [1] [[DISCUSS]

[jira] [Created] (FLINK-30783) Add pull request template for AWS Connectors repo

2023-01-25 Thread Hong Liang Teoh (Jira)
Hong Liang Teoh created FLINK-30783: --- Summary: Add pull request template for AWS Connectors repo Key: FLINK-30783 URL: https://issues.apache.org/jira/browse/FLINK-30783 Project: Flink

[jira] [Created] (FLINK-30837) Remove dependency of MutableByteArrayInputStream from flink-avro-glue-schema-registry

2023-01-30 Thread Hong Liang Teoh (Jira)
Hong Liang Teoh created FLINK-30837: --- Summary: Remove dependency of MutableByteArrayInputStream from flink-avro-glue-schema-registry Key: FLINK-30837 URL: https://issues.apache.org/jira/browse/FLINK-30837

[jira] [Created] (FLINK-29900) Implement Table API for DynamoDB Sink

2022-11-05 Thread Hong Liang Teoh (Jira)
Hong Liang Teoh created FLINK-29900: --- Summary: Implement Table API for DynamoDB Sink Key: FLINK-29900 URL: https://issues.apache.org/jira/browse/FLINK-29900 Project: Flink Issue Type:

[jira] [Created] (FLINK-29909) Standardise connector package names

2022-11-05 Thread Hong Liang Teoh (Jira)
Hong Liang Teoh created FLINK-29909: --- Summary: Standardise connector package names Key: FLINK-29909 URL: https://issues.apache.org/jira/browse/FLINK-29909 Project: Flink Issue Type:

[jira] [Created] (FLINK-30853) Make clear the public API for flink-avro

2023-01-31 Thread Hong Liang Teoh (Jira)
Hong Liang Teoh created FLINK-30853: --- Summary: Make clear the public API for flink-avro Key: FLINK-30853 URL: https://issues.apache.org/jira/browse/FLINK-30853 Project: Flink Issue Type:

[jira] [Commented] (FLINK-30949) Sync flink-connector-aws-base from Flink main to flink-connector-aws

2023-03-14 Thread Hong Liang Teoh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30949?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17700370#comment-17700370 ] Hong Liang Teoh commented on FLINK-30949: - Did a diff between

[jira] [Closed] (FLINK-30949) Sync flink-connector-aws-base from Flink main to flink-connector-aws

2023-03-14 Thread Hong Liang Teoh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30949?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hong Liang Teoh closed FLINK-30949. --- Resolution: Not A Problem > Sync flink-connector-aws-base from Flink main to

[jira] [Created] (FLINK-31159) Release Testing: Verify FLINK-30583 Provide the flame graph to the subtask level

2023-02-20 Thread Hong Liang Teoh (Jira)
Hong Liang Teoh created FLINK-31159: --- Summary: Release Testing: Verify FLINK-30583 Provide the flame graph to the subtask level Key: FLINK-31159 URL: https://issues.apache.org/jira/browse/FLINK-31159

[jira] [Comment Edited] (FLINK-30926) [Umbrella] Test Flink Release 1.17

2023-02-20 Thread Hong Liang Teoh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30926?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17691301#comment-17691301 ] Hong Liang Teoh edited comment on FLINK-30926 at 2/20/23 9:26 PM: -- h2.

[jira] [Comment Edited] (FLINK-30926) [Umbrella] Test Flink Release 1.17

2023-02-20 Thread Hong Liang Teoh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30926?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17691301#comment-17691301 ] Hong Liang Teoh edited comment on FLINK-30926 at 2/20/23 9:26 PM: -- h2.

[jira] [Commented] (FLINK-30926) [Umbrella] Test Flink Release 1.17

2023-02-20 Thread Hong Liang Teoh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30926?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17691301#comment-17691301 ] Hong Liang Teoh commented on FLINK-30926: - h4. Test Outline We want to submit a job that has

[jira] [Commented] (FLINK-31159) Release Testing: Verify FLINK-30583 Provide the flame graph to the subtask level

2023-02-20 Thread Hong Liang Teoh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31159?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17691304#comment-17691304 ] Hong Liang Teoh commented on FLINK-31159: - h2. Test Outline We want to submit a job that has

[jira] [Updated] (FLINK-31159) Release Testing: Verify FLINK-30583 Provide the flame graph to the subtask level

2023-02-20 Thread Hong Liang Teoh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31159?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hong Liang Teoh updated FLINK-31159: Attachment: (was: Apache_Flink_Web_Dashboard-1.png) > Release Testing: Verify

[jira] [Updated] (FLINK-31159) Release Testing: Verify FLINK-30583 Provide the flame graph to the subtask level

2023-02-20 Thread Hong Liang Teoh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31159?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hong Liang Teoh updated FLINK-31159: Attachment: Apache_Flink_Web_Dashboard-1.png > Release Testing: Verify FLINK-30583

[jira] [Updated] (FLINK-31159) Release Testing: Verify FLINK-30583 Provide the flame graph to the subtask level

2023-02-20 Thread Hong Liang Teoh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31159?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hong Liang Teoh updated FLINK-31159: Attachment: Apache_Flink_Web_Dashboard-1.png > Release Testing: Verify FLINK-30583

[jira] [Comment Edited] (FLINK-31159) Release Testing: Verify FLINK-30583 Provide the flame graph to the subtask level

2023-02-20 Thread Hong Liang Teoh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31159?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17691304#comment-17691304 ] Hong Liang Teoh edited comment on FLINK-31159 at 2/20/23 9:35 PM: -- h2.

[jira] [Updated] (FLINK-31159) Release Testing: Verify FLINK-30583 Provide the flame graph to the subtask level

2023-02-20 Thread Hong Liang Teoh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31159?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hong Liang Teoh updated FLINK-31159: Attachment: Apache_Flink_Web_Dashboard.png > Release Testing: Verify FLINK-30583 Provide

[jira] (FLINK-30926) [Umbrella] Test Flink Release 1.17

2023-02-20 Thread Hong Liang Teoh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30926 ] Hong Liang Teoh deleted comment on FLINK-30926: - was (Author: JIRAUSER292614): h2. Test Outline We want to submit a job that has parallelism > 1 and only 1 subtask is busy. We want to

[jira] [Comment Edited] (FLINK-30926) [Umbrella] Test Flink Release 1.17

2023-02-20 Thread Hong Liang Teoh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30926?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17691301#comment-17691301 ] Hong Liang Teoh edited comment on FLINK-30926 at 2/20/23 9:28 PM: -- h2.

[jira] [Updated] (FLINK-30926) [Umbrella] Test Flink Release 1.17

2023-02-20 Thread Hong Liang Teoh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30926?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hong Liang Teoh updated FLINK-30926: Attachment: (was: Apache_Flink_Web_Dashboard.png) > [Umbrella] Test Flink Release

[jira] [Updated] (FLINK-31159) Release Testing: Verify FLINK-30583 Provide the flame graph to the subtask level

2023-02-20 Thread Hong Liang Teoh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31159?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hong Liang Teoh updated FLINK-31159: Attachment: subtask3.png > Release Testing: Verify FLINK-30583 Provide the flame graph to

[jira] [Updated] (FLINK-31159) Release Testing: Verify FLINK-30583 Provide the flame graph to the subtask level

2023-02-20 Thread Hong Liang Teoh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31159?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hong Liang Teoh updated FLINK-31159: Attachment: subtask0.png > Release Testing: Verify FLINK-30583 Provide the flame graph to

[jira] [Updated] (FLINK-31159) Release Testing: Verify FLINK-30583 Provide the flame graph to the subtask level

2023-02-20 Thread Hong Liang Teoh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31159?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hong Liang Teoh updated FLINK-31159: Attachment: all_subtasks.png > Release Testing: Verify FLINK-30583 Provide the flame

[jira] [Updated] (FLINK-31159) Release Testing: Verify FLINK-30583 Provide the flame graph to the subtask level

2023-02-20 Thread Hong Liang Teoh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31159?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hong Liang Teoh updated FLINK-31159: Attachment: Map_record_distribution.png > Release Testing: Verify FLINK-30583 Provide the

[jira] [Updated] (FLINK-31159) Release Testing: Verify FLINK-30583 Provide the flame graph to the subtask level

2023-02-20 Thread Hong Liang Teoh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31159?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hong Liang Teoh updated FLINK-31159: Attachment: (was: Apache_Flink_Web_Dashboard.png) > Release Testing: Verify

[jira] [Updated] (FLINK-31159) Release Testing: Verify FLINK-30583 Provide the flame graph to the subtask level

2023-02-20 Thread Hong Liang Teoh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31159?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hong Liang Teoh updated FLINK-31159: Attachment: (was: Apache_Flink_Web_Dashboard-1.png) > Release Testing: Verify

[jira] [Created] (FLINK-31108) Use StreamARN for API calls in Kinesis Connector

2023-02-16 Thread Hong Liang Teoh (Jira)
Hong Liang Teoh created FLINK-31108: --- Summary: Use StreamARN for API calls in Kinesis Connector Key: FLINK-31108 URL: https://issues.apache.org/jira/browse/FLINK-31108 Project: Flink Issue

[jira] [Updated] (FLINK-31108) Use StreamARN for API calls in Kinesis Connector

2023-02-16 Thread Hong Liang Teoh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31108?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hong Liang Teoh updated FLINK-31108: Description: Currently, the FlinkKinesisConsumer (Polling + EFO) + FlinkKinesisProducer

[jira] [Closed] (FLINK-31159) Release Testing: Verify FLINK-30583 Provide the flame graph to the subtask level

2023-02-21 Thread Hong Liang Teoh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31159?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hong Liang Teoh closed FLINK-31159. --- > Release Testing: Verify FLINK-30583 Provide the flame graph to the subtask > level >

  1   2   3   >