[jira] [Assigned] (FLINK-35559) Shading issue cause class conflict

2024-06-10 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35559?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer reassigned FLINK-35559: - Assignee: Aleksandr Pilipenko > Shading issue cause class conflict > --

[jira] [Assigned] (FLINK-35435) [FLIP-451] Introduce timeout configuration to AsyncSink

2024-06-10 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35435?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer reassigned FLINK-35435: - Assignee: Ahmed Hamdy > [FLIP-451] Introduce timeout configuration to AsyncSink > -

[jira] [Resolved] (FLINK-35435) [FLIP-451] Introduce timeout configuration to AsyncSink

2024-06-10 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35435?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer resolved FLINK-35435. --- Resolution: Done > [FLIP-451] Introduce timeout configuration to AsyncSink > ---

[jira] [Commented] (FLINK-35435) [FLIP-451] Introduce timeout configuration to AsyncSink

2024-06-10 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35435?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17853713#comment-17853713 ] Danny Cranmer commented on FLINK-35435: --- Merged commit [{{c9def98}}|https://githu

[jira] [Commented] (FLINK-30400) Stop bundling connector-base in externalized connectors

2024-06-11 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30400?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17853965#comment-17853965 ] Danny Cranmer commented on FLINK-30400: --- I agree this is frustrating. It is a simi

[jira] [Commented] (FLINK-35137) Release flink-connector-jdbc v3.2.0 for Flink 1.19

2024-07-05 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35137?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17863203#comment-17863203 ] Danny Cranmer commented on FLINK-35137: --- [~wanghe] where are you referring to? I s

[jira] [Assigned] (FLINK-35299) FlinkKinesisConsumer does not respect StreamInitialPosition for new Kinesis Stream when restoring from snapshot

2024-07-08 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35299?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer reassigned FLINK-35299: - Assignee: Antonio Silva > FlinkKinesisConsumer does not respect StreamInitialPosition f

[jira] [Assigned] (FLINK-34429) Adding K8S Annotations to Internal Service

2024-02-13 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34429?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer reassigned FLINK-34429: - Assignee: Barak Ben-Nathan > Adding K8S Annotations to Internal Service > -

[jira] [Commented] (FLINK-34429) Adding K8S Annotations to Internal Service

2024-02-13 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34429?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17816929#comment-17816929 ] Danny Cranmer commented on FLINK-34429: --- Thanks for raising [~bara...@gmail.com] ,

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

2024-02-22 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34490?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17819641#comment-17819641 ] Danny Cranmer commented on FLINK-34490: --- Assigning to [~a.pilipenko] to take a loo

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

2024-02-22 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34490?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer reassigned FLINK-34490: - Assignee: Aleksandr Pilipenko > flink-connector-kinesis not correctly supporting creden

[jira] [Updated] (FLINK-34429) Adding K8S Annotations to Internal Service

2024-02-26 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34429?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer updated FLINK-34429: -- Fix Version/s: 1.20.0 > Adding K8S Annotations to Internal Service > -

[jira] [Resolved] (FLINK-34429) Adding K8S Annotations to Internal Service

2024-03-05 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34429?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer resolved FLINK-34429. --- Resolution: Done > Adding K8S Annotations to Internal Service >

[jira] [Commented] (FLINK-34429) Adding K8S Annotations to Internal Service

2024-03-05 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34429?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17823893#comment-17823893 ] Danny Cranmer commented on FLINK-34429: --- Merged commit [{{70975b2}}|https://githu

[jira] [Commented] (FLINK-34044) Kinesis Sink Cannot be Created via TableDescriptor

2024-03-13 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34044?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17825981#comment-17825981 ] Danny Cranmer commented on FLINK-34044: --- Thanks [~chalixar] . I am on vacation thi

[jira] [Assigned] (FLINK-32230) Deadlock in AWS Kinesis Data Streams AsyncSink connector

2023-10-18 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32230?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer reassigned FLINK-32230: - Assignee: Antonio Vespoli (was: Ahmed Hamdy) > Deadlock in AWS Kinesis Data Streams As

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

2023-10-18 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32230?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17776551#comment-17776551 ] Danny Cranmer commented on FLINK-32230: --- Merged commit [{{37975ca}}|https://githu

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

2023-10-18 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32230?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer updated FLINK-32230: -- Affects Version/s: aws-connector-4.1.0 aws-connector-3.0.0 > Deadlock i

[jira] [Commented] (FLINK-33279) KinesisStream e2e tests running/failing on PR

2023-10-19 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33279?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=1117#comment-1117 ] Danny Cranmer commented on FLINK-33279: --- Merged commit [{{a1eb725}}|https://githu

[jira] [Resolved] (FLINK-33279) KinesisStream e2e tests running/failing on PR

2023-10-19 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33279?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer resolved FLINK-33279. --- Resolution: Fixed > KinesisStream e2e tests running/failing on PR > ---

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

2023-10-19 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33259?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer reassigned FLINK-33259: - Assignee: Aleksandr Pilipenko > flink-connector-aws should use/extend the common connec

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

2023-10-19 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33259?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer updated FLINK-33259: -- Fix Version/s: aws-connector-4.2.0 > flink-connector-aws should use/extend the common connecto

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

2023-10-19 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33259?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer updated FLINK-33259: -- Component/s: Connectors / AWS > flink-connector-aws should use/extend the common connector wor

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

2023-10-19 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33259?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer updated FLINK-33259: -- Affects Version/s: aws-connector-4.1.0 aws-connector-3.0.0 > flink-conn

[jira] [Commented] (FLINK-33181) Table using `kinesis` connector can not be used for both read & write operations if it's defined with unsupported sink property

2023-10-19 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33181?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=1198#comment-1198 ] Danny Cranmer commented on FLINK-33181: --- Merged commit [{{76d791f}}|https://githu

[jira] [Resolved] (FLINK-33181) Table using `kinesis` connector can not be used for both read & write operations if it's defined with unsupported sink property

2023-10-19 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33181?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer resolved FLINK-33181. --- Resolution: Fixed > Table using `kinesis` connector can not be used for both read & write >

[jira] [Comment Edited] (FLINK-32230) Deadlock in AWS Kinesis Data Streams AsyncSink connector

2023-10-19 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32230?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17776551#comment-17776551 ] Danny Cranmer edited comment on FLINK-32230 at 10/19/23 11:19 AM:

[jira] [Resolved] (FLINK-32230) Deadlock in AWS Kinesis Data Streams AsyncSink connector

2023-10-19 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32230?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer resolved FLINK-32230. --- Resolution: Fixed > Deadlock in AWS Kinesis Data Streams AsyncSink connector > -

[jira] [Commented] (FLINK-33181) Table using `kinesis` connector can not be used for both read & write operations if it's defined with unsupported sink property

2023-10-19 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33181?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=1202#comment-1202 ] Danny Cranmer commented on FLINK-33181: --- [~chalixar] I have used it before for loa

[jira] [Assigned] (FLINK-29549) Add Aws Glue Catalog support in Flink

2023-10-26 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29549?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer reassigned FLINK-29549: - Assignee: Samrat Deb > Add Aws Glue Catalog support in Flink >

[jira] [Commented] (FLINK-29549) Add Aws Glue Catalog support in Flink

2023-10-26 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29549?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17779953#comment-17779953 ] Danny Cranmer commented on FLINK-29549: --- [~martijnvisser] yes, but have not had ca

[jira] [Created] (FLINK-33409) Bump Guava to address CVE-2020-8908/CVE-2023-2976

2023-10-31 Thread Danny Cranmer (Jira)
Danny Cranmer created FLINK-33409: - Summary: Bump Guava to address CVE-2020-8908/CVE-2023-2976 Key: FLINK-33409 URL: https://issues.apache.org/jira/browse/FLINK-33409 Project: Flink Issue Typ

[jira] [Assigned] (FLINK-33409) Bump Guava to address CVE-2020-8908/CVE-2023-2976

2023-10-31 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33409?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer reassigned FLINK-33409: - Assignee: Danny Cranmer > Bump Guava to address CVE-2020-8908/CVE-2023-2976 > -

[jira] [Updated] (FLINK-33409) Bump Guava in AWS Connectors to address CVE-2020-8908/CVE-2023-2976

2023-10-31 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33409?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer updated FLINK-33409: -- Summary: Bump Guava in AWS Connectors to address CVE-2020-8908/CVE-2023-2976 (was: Bump Guava

[jira] [Commented] (FLINK-33409) Bump Guava in AWS Connectors to address CVE-2020-8908/CVE-2023-2976

2023-10-31 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33409?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17781303#comment-17781303 ] Danny Cranmer commented on FLINK-33409: ---  merged commit  [{{23624ab}}|https://gith

[jira] [Resolved] (FLINK-33409) Bump Guava in AWS Connectors to address CVE-2020-8908/CVE-2023-2976

2023-10-31 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33409?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer resolved FLINK-33409. --- Resolution: Fixed > Bump Guava in AWS Connectors to address CVE-2020-8908/CVE-2023-2976 > --

[jira] [Created] (FLINK-33413) Bump Avro in AWS Connectors to address CVE-2023-39410

2023-10-31 Thread Danny Cranmer (Jira)
Danny Cranmer created FLINK-33413: - Summary: Bump Avro in AWS Connectors to address CVE-2023-39410 Key: FLINK-33413 URL: https://issues.apache.org/jira/browse/FLINK-33413 Project: Flink Issue

[jira] [Updated] (FLINK-33413) Bump Avro in AWS Connectors to address CVE-2023-39410

2023-10-31 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33413?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer updated FLINK-33413: -- Description: Bump org.apache.avro:avro {{v1.11.1}} to {{v1.11.3}} > Bump Avro in AWS Connector

[jira] [Assigned] (FLINK-33413) Bump Avro in AWS Connectors to address CVE-2023-39410

2023-10-31 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33413?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer reassigned FLINK-33413: - Assignee: Danny Cranmer > Bump Avro in AWS Connectors to address CVE-2023-39410 > -

[jira] [Resolved] (FLINK-33413) Bump Avro in AWS Connectors to address CVE-2023-39410

2023-10-31 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33413?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer resolved FLINK-33413. --- Resolution: Fixed  merged commit  [{{3f4d59b}}|https://github.com/apache/flink-connector-aws

[jira] [Updated] (FLINK-24379) Support AWS Glue Schema Registry Avro for Table API

2023-10-31 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24379?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer updated FLINK-24379: -- Affects Version/s: aws-connector-4.2.0 (was: 1.14.0) > Support AWS

[jira] [Updated] (FLINK-24379) Support AWS Glue Schema Registry Avro for Table API

2023-10-31 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24379?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer updated FLINK-24379: -- Fix Version/s: aws-connector-4.3.0 (was: aws-connector-4.2.0) > Support

[jira] [Updated] (FLINK-25779) Define ConfigOption for aws, scan and sink map in Kinesis

2023-10-31 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25779?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer updated FLINK-25779: -- Affects Version/s: aws-connector-4.2.0 > Define ConfigOption for aws, scan and sink map in Kin

[jira] [Updated] (FLINK-25779) Define ConfigOption for aws, scan and sink map in Kinesis

2023-10-31 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25779?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer updated FLINK-25779: -- Fix Version/s: aws-connector-4.3.0 (was: aws-connector-4.2.0) > Define

[jira] [Assigned] (FLINK-24379) Support AWS Glue Schema Registry Avro for Table API

2023-10-31 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24379?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer reassigned FLINK-24379: - Assignee: (was: Karthi Thyagarajan) > Support AWS Glue Schema Registry Avro for Tab

[jira] [Updated] (FLINK-31922) Port over Kinesis Client configurations for retry and backoff

2023-10-31 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31922?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer updated FLINK-31922: -- Fix Version/s: aws-connector-4.3.0 (was: aws-connector-4.2.0) > Port ov

[jira] [Updated] (FLINK-31922) Port over Kinesis Client configurations for retry and backoff

2023-10-31 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31922?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer updated FLINK-31922: -- Affects Version/s: aws-connector-4.2.0 > Port over Kinesis Client configurations for retry and

[jira] [Updated] (FLINK-31872) Add Support for Configuring AIMD Ratelimiting strategy parameters by Sink users for KinesisStreamsSink

2023-10-31 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31872?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer updated FLINK-31872: -- Affects Version/s: aws-connector-4.2.0 > Add Support for Configuring AIMD Ratelimiting strateg

[jira] [Updated] (FLINK-31872) Add Support for Configuring AIMD Ratelimiting strategy parameters by Sink users for KinesisStreamsSink

2023-10-31 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31872?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer updated FLINK-31872: -- Fix Version/s: aws-connector-4.3.0 (was: aws-connector-4.2.0) > Add Sup

[jira] [Updated] (FLINK-32116) FlinkKinesisConsumer cannot stop-with-savepoint when configured with watermark assigner and watermark tracker

2023-10-31 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32116?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer updated FLINK-32116: -- Fix Version/s: aws-connector-4.3.0 (was: aws-connector-4.2.0) > FlinkKi

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

2023-10-31 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33073?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer resolved FLINK-33073. --- Resolution: Fixed > Implement end-to-end tests for the Kinesis Streams Sink > --

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

2023-10-31 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33072?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer updated FLINK-33072: -- Fix Version/s: aws-connector-4.2.0 (was: 2.0.0) > Implement end-to-end

[jira] [Updated] (FLINK-32116) FlinkKinesisConsumer cannot stop-with-savepoint when configured with watermark assigner and watermark tracker

2023-10-31 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32116?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer updated FLINK-32116: -- Affects Version/s: aws-connector-4.2.0 (was: aws-connector-4.1.0) >

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

2023-10-31 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33072?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer resolved FLINK-33072. --- Assignee: Hong Liang Teoh Resolution: Done > Implement end-to-end tests for AWS Kinesi

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

2023-10-31 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33259?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer updated FLINK-33259: -- Affects Version/s: aws-connector-4.2.0 (was: aws-connector-4.1.0) >

[jira] [Updated] (FLINK-33260) Custom Error Handling for Kinesis Consumer

2023-10-31 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33260?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer updated FLINK-33260: -- Fix Version/s: aws-connector-4.3.0 (was: aws-connector-4.2.0) > Custom

[jira] [Updated] (FLINK-33260) Custom Error Handling for Kinesis Consumer

2023-10-31 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33260?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer updated FLINK-33260: -- Affects Version/s: aws-connector-4.2.0 > Custom Error Handling for Kinesis Consumer >

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

2023-10-31 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33259?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer updated FLINK-33259: -- Fix Version/s: aws-connector-4.3.0 (was: aws-connector-4.2.0) > flink-c

[jira] [Assigned] (FLINK-24379) Support AWS Glue Schema Registry Avro for Table API

2023-10-31 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24379?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer reassigned FLINK-24379: - Assignee: Lorenzo Nicora > Support AWS Glue Schema Registry Avro for Table API > --

[jira] [Updated] (FLINK-33049) Project website refresh Code Samples Widget

2023-11-01 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33049?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer updated FLINK-33049: -- Description: Implement Java/Python/SQL code samples widget as per the FLIP:  - https://cwiki

[jira] [Updated] (FLINK-33049) Project website refresh Code Samples Widget

2023-11-01 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33049?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer updated FLINK-33049: -- Parent: (was: FLINK-33046) Issue Type: New Feature (was: Sub-task) > Project webs

[jira] [Updated] (FLINK-33049) Project website refresh Code Samples Widget

2023-11-01 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33049?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer updated FLINK-33049: -- Description: Implement Java/Python/SQL code samples as per the FLIP !https://cwiki.apache.org

[jira] [Resolved] (FLINK-33046) [FLIP-333] Redesign Apache Flink website

2023-11-01 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33046?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer resolved FLINK-33046. --- Resolution: Done > [FLIP-333] Redesign Apache Flink website > --

[jira] [Updated] (FLINK-33049) Flink Website: Code Samples Widget

2023-11-01 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33049?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer updated FLINK-33049: -- Summary: Flink Website: Code Samples Widget (was: Project website refresh Code Samples Widget

[jira] [Updated] (FLINK-32024) Short code related to externalized connector retrieve version from its own data yaml

2023-11-03 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32024?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer updated FLINK-32024: -- Fix Version/s: opensearch-1.1.0 opensearch-1.0.2 > Short code related to ex

[jira] [Updated] (FLINK-30998) Add optional exception handler to flink-connector-opensearch

2023-11-03 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30998?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer updated FLINK-30998: -- Fix Version/s: opensearch-1.1.0 (was: opensearch-1.0.2) > Add optional

[jira] [Updated] (FLINK-32425) Fix Opensearch Connector wrong empty doc link

2023-11-03 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32425?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer updated FLINK-32425: -- Fix Version/s: opensearch-1.1.0 > Fix Opensearch Connector wrong empty doc link >

[jira] [Updated] (FLINK-32228) Bump testcontainers to 1.18.2

2023-11-03 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32228?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer updated FLINK-32228: -- Fix Version/s: opensearch-1.1.0 > Bump testcontainers to 1.18.2 >

[jira] [Updated] (FLINK-30850) Update GCP E2E tests to updated setup so they no longer publish their JARs

2023-11-03 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30850?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer updated FLINK-30850: -- Fix Version/s: gcp-pubsub-3.1.0 > Update GCP E2E tests to updated setup so they no longer publ

[jira] [Updated] (FLINK-31923) Connector weekly runs are only testing main branches instead of all supported branches

2023-11-03 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31923?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer updated FLINK-31923: -- Fix Version/s: gcp-pubsub-3.1.0 > Connector weekly runs are only testing main branches instead

[jira] [Updated] (FLINK-33018) GCP Pubsub PubSubConsumingTest.testStoppingConnectorWhenDeserializationSchemaIndicatesEndOfStream failed

2023-11-03 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33018?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer updated FLINK-33018: -- Fix Version/s: gcp-pubsub-3.1.0 > GCP Pubsub > PubSubConsumingTest.testStoppingConnectorWhenD

[jira] [Updated] (FLINK-32031) Flink GCP Connector having issues with Conscrypt library

2023-11-03 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32031?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer updated FLINK-32031: -- Fix Version/s: gcp-pubsub-3.1.0 > Flink GCP Connector having issues with Conscrypt library > -

[jira] [Commented] (FLINK-33260) Custom Error Handling for Kinesis Consumer

2023-11-07 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33260?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17783826#comment-17783826 ] Danny Cranmer commented on FLINK-33260: --- Merged commit [{{4c2fdd9}}|https://githu

[jira] [Commented] (FLINK-33260) Custom Error Handling for Kinesis Consumer

2023-11-07 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33260?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17783827#comment-17783827 ] Danny Cranmer commented on FLINK-33260: --- [~iemre] I have merged the EFO support. W

[jira] [Assigned] (FLINK-33560) Externalize Kinesis Python connector code

2023-11-15 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33560?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer reassigned FLINK-33560: - Assignee: Danny Cranmer > Externalize Kinesis Python connector code > -

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

2023-11-17 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33589?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer reassigned FLINK-33589: - Assignee: Aleksandr Pilipenko > Fix broken documentation page for Kinesis connector > -

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

2023-11-17 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33589?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17787414#comment-17787414 ] Danny Cranmer commented on FLINK-33589: --- Triggered docs build > Fix broken docume

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

2023-11-17 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33589?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17787413#comment-17787413 ] Danny Cranmer commented on FLINK-33589: --- Merged commit [{{536e583}}|https://githu

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

2023-11-17 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33589?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer updated FLINK-33589: -- Description: Recent change in connector version declaration in docs (FLINK-33567) resulted in

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

2023-11-20 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33589?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer updated FLINK-33589: -- Fix Version/s: 1.19.0 > Fix broken documentation page for Kinesis connector >

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

2023-11-20 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33589?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17787919#comment-17787919 ] Danny Cranmer commented on FLINK-33589: --- Looks like this is now resolved. Thanks [

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

2023-11-20 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33589?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer resolved FLINK-33589. --- Resolution: Fixed > Fix broken documentation page for Kinesis connector > --

[jira] [Commented] (FLINK-34044) Kinesis Sink Cannot be Created via TableDescriptor

2024-01-10 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34044?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17805021#comment-17805021 ] Danny Cranmer commented on FLINK-34044: --- Thanks for reporting this, [~tilman151] .

[jira] [Commented] (FLINK-34076) flink-connector-base missing fails kinesis table sink to create

2024-01-15 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34076?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17806756#comment-17806756 ] Danny Cranmer commented on FLINK-34076: --- > flink-connector-base has already been i

[jira] [Commented] (FLINK-34076) flink-connector-base missing fails kinesis table sink to create

2024-01-15 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34076?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17806797#comment-17806797 ] Danny Cranmer commented on FLINK-34076: --- [~jiabao.sun]  Ah, I missed that. Interes

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

2024-01-29 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34260?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17811893#comment-17811893 ] Danny Cranmer commented on FLINK-34260: --- Hey [~jiabao.sun] , thanks for offering,

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

2024-01-29 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34260?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer reassigned FLINK-34260: - Assignee: Aleksandr Pilipenko > Update flink-connector-aws to be compatible with update

[jira] [Updated] (FLINK-31856) Add support for Opensearch Connector REST client customization

2024-02-01 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31856?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer updated FLINK-31856: -- Fix Version/s: (was: opensearch-1.1.0) > Add support for Opensearch Connector REST client

[jira] [Updated] (FLINK-31856) Add support for Opensearch Connector REST client customization

2024-02-01 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31856?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer updated FLINK-31856: -- Fix Version/s: opensearch-1.1.0 > Add support for Opensearch Connector REST client customizati

[jira] [Created] (FLINK-34339) Add connector abstraction layer to remove reliance on AWWS SDK classes

2024-02-02 Thread Danny Cranmer (Jira)
Danny Cranmer created FLINK-34339: - Summary: Add connector abstraction layer to remove reliance on AWWS SDK classes Key: FLINK-34339 URL: https://issues.apache.org/jira/browse/FLINK-34339 Project: Fli

[jira] [Updated] (FLINK-34339) Add connector abstraction layer to remove reliance on AWS SDK classes

2024-02-02 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34339?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer updated FLINK-34339: -- Summary: Add connector abstraction layer to remove reliance on AWS SDK classes (was: Add conn

[jira] [Updated] (FLINK-34339) Add connector abstraction layer to remove reliance on AWS SDK classes

2024-02-02 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34339?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer updated FLINK-34339: -- Component/s: Connectors / Kinesis > Add connector abstraction layer to remove reliance on AWS

[jira] [Created] (FLINK-34340) Add support for DDB Streams

2024-02-02 Thread Danny Cranmer (Jira)
Danny Cranmer created FLINK-34340: - Summary: Add support for DDB Streams Key: FLINK-34340 URL: https://issues.apache.org/jira/browse/FLINK-34340 Project: Flink Issue Type: Sub-task

[jira] [Updated] (FLINK-31980) Implement support for EFO in new KDS Source

2024-02-02 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31980?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer updated FLINK-31980: -- Component/s: Connectors / Kinesis > Implement support for EFO in new KDS Source >

[jira] [Updated] (FLINK-31980) Implement support for EFO in new KDS Source

2024-02-02 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31980?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer updated FLINK-31980: -- Summary: Implement support for EFO in new KDS Source (was: Implement support for EFO in new S

[jira] [Updated] (FLINK-31987) Implement KDS Table API support

2024-02-02 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31987?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer updated FLINK-31987: -- Summary: Implement KDS Table API support (was: Implement Table API support) > Implement KDS T

[jira] [Updated] (FLINK-31987) Implement KDS Table API support

2024-02-02 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31987?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer updated FLINK-31987: -- Component/s: Connectors / Kinesis > Implement KDS Table API support >

[jira] [Created] (FLINK-34341) Implement DDB Streams Table API support

2024-02-02 Thread Danny Cranmer (Jira)
Danny Cranmer created FLINK-34341: - Summary: Implement DDB Streams Table API support Key: FLINK-34341 URL: https://issues.apache.org/jira/browse/FLINK-34341 Project: Flink Issue Type: Sub-tas

[jira] [Updated] (FLINK-34341) Implement DDB Streams Table API support

2024-02-02 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34341?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer updated FLINK-34341: -- Reporter: Danny Cranmer (was: Hong Liang Teoh) > Implement DDB Streams Table API support > --

[jira] [Updated] (FLINK-34341) Implement DDB Streams Table API support

2024-02-02 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34341?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer updated FLINK-34341: -- Description: Implement Table API support for DDB Streams Source.   Consider: * Configuratio

  1   2   3   4   5   6   7   8   9   10   >