[jira] [Commented] (FLINK-36651) Fix CI tests for ElasticSearch Connector

[ https://issues.apache.org/jira/browse/FLINK-36651?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17898589#comment-17898589 ] Danny Cranmer commented on FLINK-36651: --- Merged commit [{{9b545d0}}|https://githu

[jira] [Updated] (FLINK-36651) Fix CI tests for ElasticSearch Connector

[ https://issues.apache.org/jira/browse/FLINK-36651?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer updated FLINK-36651: -- Fix Version/s: elasticsearch-3.1.0 > Fix CI tests for ElasticSearch Connector > --

[jira] [Assigned] (FLINK-36651) Fix CI tests for ElasticSearch Connector

[ https://issues.apache.org/jira/browse/FLINK-36651?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer reassigned FLINK-36651: - Assignee: Ahmed Hamdy > Fix CI tests for ElasticSearch Connector >

[jira] [Commented] (FLINK-36595) Supported Flink version for connector documentation does not get matched for 1.20

[ https://issues.apache.org/jira/browse/FLINK-36595?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17892460#comment-17892460 ] Danny Cranmer commented on FLINK-36595: --- Merged commit [{{06159a2}}|https://githu

[jira] [Resolved] (FLINK-36595) Supported Flink version for connector documentation does not get matched for 1.20

[ https://issues.apache.org/jira/browse/FLINK-36595?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer resolved FLINK-36595. --- Resolution: Fixed > Supported Flink version for connector documentation does not get matched

[jira] [Assigned] (FLINK-36595) Supported Flink version for connector documentation does not get matched for 1.20

[ https://issues.apache.org/jira/browse/FLINK-36595?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer reassigned FLINK-36595: - Assignee: Aleksandr Pilipenko > Supported Flink version for connector documentation doe

[jira] [Updated] (FLINK-36595) Supported Flink version for connector documentation does not get matched for 1.20

[ https://issues.apache.org/jira/browse/FLINK-36595?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer updated FLINK-36595: -- Fix Version/s: kafka-3.4.0 > Supported Flink version for connector documentation does not get

[jira] [Comment Edited] (FLINK-36420) Upgrade org.apache.avro:avro to 1.11.4

[ https://issues.apache.org/jira/browse/FLINK-36420?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17886786#comment-17886786 ] Danny Cranmer edited comment on FLINK-36420 at 10/4/24 7:54 AM: --

[jira] [Resolved] (FLINK-36420) Upgrade org.apache.avro:avro to 1.11.4

[ https://issues.apache.org/jira/browse/FLINK-36420?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer resolved FLINK-36420. --- Resolution: Fixed > Upgrade org.apache.avro:avro to 1.11.4 > ---

[jira] [Comment Edited] (FLINK-36420) Upgrade org.apache.avro:avro to 1.11.4

[ https://issues.apache.org/jira/browse/FLINK-36420?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17886786#comment-17886786 ] Danny Cranmer edited comment on FLINK-36420 at 10/4/24 7:54 AM: --

[jira] [Resolved] (FLINK-36422) Broken PyFlink jar download link for Kafka connector

[ https://issues.apache.org/jira/browse/FLINK-36422?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer resolved FLINK-36422. --- Resolution: Fixed > Broken PyFlink jar download link for Kafka connector > -

[jira] [Commented] (FLINK-36181) Drop support for Java 8 and use Java 17 by default

[ https://issues.apache.org/jira/browse/FLINK-36181?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17886789#comment-17886789 ] Danny Cranmer commented on FLINK-36181: --- Thanks [~a.pilipenko]  Merged commit [{{

[jira] [Comment Edited] (FLINK-36181) Drop support for Java 8 and use Java 17 by default

[ https://issues.apache.org/jira/browse/FLINK-36181?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17886782#comment-17886782 ] Danny Cranmer edited comment on FLINK-36181 at 10/3/24 8:36 PM: --

[jira] [Comment Edited] (FLINK-36420) Upgrade org.apache.avro:avro to 1.11.4

[ https://issues.apache.org/jira/browse/FLINK-36420?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17886786#comment-17886786 ] Danny Cranmer edited comment on FLINK-36420 at 10/3/24 8:28 PM: --

[jira] [Commented] (FLINK-36181) Drop support for Java 8 and use Java 17 by default

[ https://issues.apache.org/jira/browse/FLINK-36181?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17886782#comment-17886782 ] Danny Cranmer commented on FLINK-36181: --- [~sxnan] it looks like this might have br

[jira] [Assigned] (FLINK-36181) Drop support for Java 8 and use Java 17 by default

[ https://issues.apache.org/jira/browse/FLINK-36181?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer reassigned FLINK-36181: - Assignee: Xuannan Su > Drop support for Java 8 and use Java 17 by default > ---

[jira] [Updated] (FLINK-36422) Broken PyFlink jar download link for Kafka connector

[ https://issues.apache.org/jira/browse/FLINK-36422?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer updated FLINK-36422: -- Fix Version/s: (was: kafka-3.3.0) > Broken PyFlink jar download link for Kafka connector >

[jira] [Commented] (FLINK-36422) Broken PyFlink jar download link for Kafka connector

[ https://issues.apache.org/jira/browse/FLINK-36422?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17886777#comment-17886777 ] Danny Cranmer commented on FLINK-36422: --- Merged commit [{{ac8fa12}}|https://githu

[jira] [Assigned] (FLINK-35141) Release flink-connector-pulsar v4.2.0 for Flink 1.19

[ https://issues.apache.org/jira/browse/FLINK-35141?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer reassigned FLINK-35141: - Assignee: (was: Danny Cranmer) > Release flink-connector-pulsar v4.2.0 for Flink 1.

[jira] [Assigned] (FLINK-35142) Release flink-connector-rabbitmq v3.1.0 for Flink 1.19

[ https://issues.apache.org/jira/browse/FLINK-35142?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer reassigned FLINK-35142: - Assignee: (was: Danny Cranmer) > Release flink-connector-rabbitmq v3.1.0 for Flink

[jira] [Updated] (FLINK-36422) Broken PyFlink jar download link for Kafka connector

[ https://issues.apache.org/jira/browse/FLINK-36422?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer updated FLINK-36422: -- Fix Version/s: kafka-3.3.0 > Broken PyFlink jar download link for Kafka connector > --

[jira] [Assigned] (FLINK-36422) Broken PyFlink jar download link for Kafka connector

[ https://issues.apache.org/jira/browse/FLINK-36422?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer reassigned FLINK-36422: - Assignee: Aleksandr Pilipenko > Broken PyFlink jar download link for Kafka connector >

[jira] [Updated] (FLINK-36420) Upgrade org.apache.avro:avro to 1.11.4

[ https://issues.apache.org/jira/browse/FLINK-36420?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer updated FLINK-36420: -- Fix Version/s: (was: kafka-4.0.0) > Upgrade org.apache.avro:avro to 1.11.4 > -

[jira] [Commented] (FLINK-36420) Upgrade org.apache.avro:avro to 1.11.4

[ https://issues.apache.org/jira/browse/FLINK-36420?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17886769#comment-17886769 ] Danny Cranmer commented on FLINK-36420: --- [~davidradl] I will update the Avro versi

[jira] [Created] (FLINK-36420) Upgrade org.apache.avro:avro to 1.11.4

Danny Cranmer created FLINK-36420: - Summary: Upgrade org.apache.avro:avro to 1.11.4 Key: FLINK-36420 URL: https://issues.apache.org/jira/browse/FLINK-36420 Project: Flink Issue Type: Technica

[jira] [Assigned] (FLINK-36420) Upgrade org.apache.avro:avro to 1.11.4

[ https://issues.apache.org/jira/browse/FLINK-36420?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer reassigned FLINK-36420: - Assignee: Danny Cranmer > Upgrade org.apache.avro:avro to 1.11.4 >

[jira] [Resolved] (FLINK-36234) Add 1.20 to PreviousDocs list

[ https://issues.apache.org/jira/browse/FLINK-36234?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer resolved FLINK-36234. --- Resolution: Fixed > Add 1.20 to PreviousDocs list > - > >

[jira] [Assigned] (FLINK-36234) Add 1.20 to PreviousDocs list

[ https://issues.apache.org/jira/browse/FLINK-36234?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer reassigned FLINK-36234: - Assignee: Aleksandr Pilipenko > Add 1.20 to PreviousDocs list > ---

[jira] [Updated] (FLINK-36057) Allow specifying ARN for AWS connector resources

[ https://issues.apache.org/jira/browse/FLINK-36057?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer updated FLINK-36057: -- Fix Version/s: aws-connector-4.4.0 (was: 1.20.0) > Allow specifying ARN

[jira] [Assigned] (FLINK-36008) Guidance for previewing connector docs contributions

[ https://issues.apache.org/jira/browse/FLINK-36008?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer reassigned FLINK-36008: - Assignee: Lorenzo Nicora > Guidance for previewing connector docs contributions > -

[jira] [Updated] (FLINK-36008) Guidance for previewing connector docs contributions

[ https://issues.apache.org/jira/browse/FLINK-36008?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer updated FLINK-36008: -- Fix Version/s: 2.0.0 > Guidance for previewing connector docs contributions >

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

[ 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] [Commented] (FLINK-35137) Release flink-connector-jdbc v3.2.0 for Flink 1.19

[ 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] [Commented] (FLINK-30400) Stop bundling connector-base in externalized connectors

[ 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-35435) [FLIP-451] Introduce timeout configuration to AsyncSink

[ 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] [Resolved] (FLINK-35435) [FLIP-451] Introduce timeout configuration to AsyncSink

[ 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] [Assigned] (FLINK-35435) [FLIP-451] Introduce timeout configuration to AsyncSink

[ 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] [Assigned] (FLINK-35559) Shading issue cause class conflict

[ 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] [Resolved] (FLINK-35138) Release flink-connector-kafka v3.2.0 for Flink 1.19

[ https://issues.apache.org/jira/browse/FLINK-35138?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer resolved FLINK-35138. --- Resolution: Done > Release flink-connector-kafka v3.2.0 for Flink 1.19 > ---

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

[ https://issues.apache.org/jira/browse/FLINK-35138?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17853102#comment-17853102 ] Danny Cranmer commented on FLINK-35138: --- I will finish this today   > Release fl

[jira] [Updated] (FLINK-34961) GitHub Actions runner statistcs can be monitored per workflow name

[ https://issues.apache.org/jira/browse/FLINK-34961?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer updated FLINK-34961: -- Fix Version/s: kafka-3.3.0 (was: kafka-3.2.0) > GitHub Actions runner s

[jira] [Updated] (FLINK-35542) ClassNotFoundException when deserializing CheckpointedOffset

[ https://issues.apache.org/jira/browse/FLINK-35542?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer updated FLINK-35542: -- Fix Version/s: jdbc-3.3.0 (was: jdbc-3.2.0) > ClassNotFoundException wh

[jira] [Updated] (FLINK-34961) GitHub Actions runner statistcs can be monitored per workflow name

[ https://issues.apache.org/jira/browse/FLINK-34961?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer updated FLINK-34961: -- Fix Version/s: jdbc-3.3.0 (was: jdbc-3.2.0) > GitHub Actions runner sta

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

[ https://issues.apache.org/jira/browse/FLINK-35137?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer resolved FLINK-35137. --- Resolution: Done > Release flink-connector-jdbc v3.2.0 for Flink 1.19 >

[jira] [Resolved] (FLINK-35133) Release flink-connector-cassandra v3.2.0 for Flink 1.19

[ https://issues.apache.org/jira/browse/FLINK-35133?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer resolved FLINK-35133. --- Resolution: Done > Release flink-connector-cassandra v3.2.0 for Flink 1.19 > ---

[jira] [Resolved] (FLINK-35132) Release flink-connector-aws v4.3.0 for Flink 1.19

[ https://issues.apache.org/jira/browse/FLINK-35132?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer resolved FLINK-35132. --- Resolution: Done > Release flink-connector-aws v4.3.0 for Flink 1.19 > -

[jira] [Resolved] (FLINK-35135) Release flink-connector-gcp-pubsub v3.1.0 for Flink 1.19

[ https://issues.apache.org/jira/browse/FLINK-35135?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer resolved FLINK-35135. --- Resolution: Done > Release flink-connector-gcp-pubsub v3.1.0 for Flink 1.19 > --

[jira] [Resolved] (FLINK-35139) Release flink-connector-mongodb v1.2.0 for Flink 1.19

[ https://issues.apache.org/jira/browse/FLINK-35139?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer resolved FLINK-35139. --- Resolution: Fixed > Release flink-connector-mongodb v1.2.0 for Flink 1.19 >

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

[ https://issues.apache.org/jira/browse/FLINK-35138?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17848533#comment-17848533 ] Danny Cranmer commented on FLINK-35138: --- We require 3 binding votes to release, we

[jira] [Resolved] (FLINK-32877) Support for HTTP connect and timeout options while writes in GCS connector

[ https://issues.apache.org/jira/browse/FLINK-32877?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer resolved FLINK-32877. --- Resolution: Done > Support for HTTP connect and timeout options while writes in GCS connecto

[jira] [Updated] (FLINK-32877) Support for HTTP connect and timeout options while writes in GCS connector

[ https://issues.apache.org/jira/browse/FLINK-32877?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer updated FLINK-32877: -- Affects Version/s: 1.18.1 1.19.0 > Support for HTTP connect and timeout

[jira] [Updated] (FLINK-32877) Support for HTTP connect and timeout options while writes in GCS connector

[ https://issues.apache.org/jira/browse/FLINK-32877?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer updated FLINK-32877: -- Fix Version/s: 1.20.0 > Support for HTTP connect and timeout options while writes in GCS conne

[jira] [Resolved] (FLINK-33506) Make AWS connectors compilable with jdk17

[ https://issues.apache.org/jira/browse/FLINK-33506?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer resolved FLINK-33506. --- Resolution: Done > Make AWS connectors compilable with jdk17 > -

[jira] [Updated] (FLINK-33506) Make AWS connectors compilable with jdk17

[ https://issues.apache.org/jira/browse/FLINK-33506?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer updated FLINK-33506: -- Fix Version/s: aws-connector-4.4.0 > Make AWS connectors compilable with jdk17 > -

[jira] [Commented] (FLINK-33506) Make AWS connectors compilable with jdk17

[ https://issues.apache.org/jira/browse/FLINK-33506?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17840712#comment-17840712 ] Danny Cranmer commented on FLINK-33506: --- Merged commit [{{c6e0abb}}|https://githu

[jira] [Updated] (FLINK-35141) Release flink-connector-pulsar v4.2.0 for Flink 1.19

[ https://issues.apache.org/jira/browse/FLINK-35141?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer updated FLINK-35141: -- Fix Version/s: pulsar-4.2.0 > Release flink-connector-pulsar v4.2.0 for Flink 1.19 > -

[jira] [Updated] (FLINK-35141) Release flink-connector-pulsar v4.2.0 for Flink 1.19

[ https://issues.apache.org/jira/browse/FLINK-35141?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer updated FLINK-35141: -- Summary: Release flink-connector-pulsar v4.2.0 for Flink 1.19 (was: Release flink-connector-p

[jira] [Assigned] (FLINK-35141) Release flink-connector-pulsar vX.X.X for Flink 1.19

[ https://issues.apache.org/jira/browse/FLINK-35141?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer reassigned FLINK-35141: - Assignee: Danny Cranmer > Release flink-connector-pulsar vX.X.X for Flink 1.19 > --

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

[ https://issues.apache.org/jira/browse/FLINK-35138?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17840028#comment-17840028 ] Danny Cranmer commented on FLINK-35138: --- RC1 Vote: https://lists.apache.org/thread

[jira] [Updated] (FLINK-35138) Release flink-connector-kafka v3.2.0 for Flink 1.19

[ https://issues.apache.org/jira/browse/FLINK-35138?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer updated FLINK-35138: -- Fix Version/s: kafka-3.2.0 > Release flink-connector-kafka v3.2.0 for Flink 1.19 > ---

[jira] [Assigned] (FLINK-35138) Release flink-connector-kafka v3.2.0 for Flink 1.19

[ https://issues.apache.org/jira/browse/FLINK-35138?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer reassigned FLINK-35138: - Assignee: Danny Cranmer > Release flink-connector-kafka v3.2.0 for Flink 1.19 > ---

[jira] [Updated] (FLINK-35138) Release flink-connector-kafka v3.2.0 for Flink 1.19

[ https://issues.apache.org/jira/browse/FLINK-35138?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer updated FLINK-35138: -- Summary: Release flink-connector-kafka v3.2.0 for Flink 1.19 (was: Release flink-connector-ka

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

[ https://issues.apache.org/jira/browse/FLINK-35133?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17839651#comment-17839651 ] Danny Cranmer commented on FLINK-35133: --- 3.2.0-RC1 Vote thread: https://lists.apa

[jira] [Updated] (FLINK-35133) Release flink-connector-cassandra v3.2.0 for Flink 1.19

[ https://issues.apache.org/jira/browse/FLINK-35133?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer updated FLINK-35133: -- Fix Version/s: cassandra-3.2.0 > Release flink-connector-cassandra v3.2.0 for Flink 1.19 > ---

[jira] [Commented] (FLINK-35174) Bump org.apache.commons:commons-compress from 1.24.0 to 1.26.1 for Flink RabbitMQ connector

[ https://issues.apache.org/jira/browse/FLINK-35174?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17838954#comment-17838954 ] Danny Cranmer commented on FLINK-35174: --- Merged commit 66e323a into apache:main >

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

[ https://issues.apache.org/jira/browse/FLINK-35137?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17838591#comment-17838591 ] Danny Cranmer edited comment on FLINK-35137 at 4/19/24 10:28 AM: -

[jira] [Comment Edited] (FLINK-35139) Release flink-connector-mongodb v1.2.0 for Flink 1.19

[ https://issues.apache.org/jira/browse/FLINK-35139?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17838086#comment-17838086 ] Danny Cranmer edited comment on FLINK-35139 at 4/19/24 10:28 AM: -

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

[ https://issues.apache.org/jira/browse/FLINK-35137?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17838181#comment-17838181 ] Danny Cranmer edited comment on FLINK-35137 at 4/19/24 10:28 AM: -

[jira] [Comment Edited] (FLINK-35132) Release flink-connector-aws v4.3.0 for Flink 1.19

[ https://issues.apache.org/jira/browse/FLINK-35132?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17838058#comment-17838058 ] Danny Cranmer edited comment on FLINK-35132 at 4/19/24 10:27 AM: -

[jira] [Comment Edited] (FLINK-35135) Release flink-connector-gcp-pubsub v3.1.0 for Flink 1.19

[ https://issues.apache.org/jira/browse/FLINK-35135?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17838590#comment-17838590 ] Danny Cranmer edited comment on FLINK-35135 at 4/19/24 10:28 AM: -

[jira] [Comment Edited] (FLINK-35139) Release flink-connector-mongodb v1.2.0 for Flink 1.19

[ https://issues.apache.org/jira/browse/FLINK-35139?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17838592#comment-17838592 ] Danny Cranmer edited comment on FLINK-35139 at 4/19/24 10:28 AM: -

[jira] [Commented] (FLINK-35132) Release flink-connector-aws v4.3.0 for Flink 1.19

[ https://issues.apache.org/jira/browse/FLINK-35132?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17838949#comment-17838949 ] Danny Cranmer commented on FLINK-35132: --- RC2 Vote: https://lists.apache.org/thread

[jira] [Updated] (FLINK-35142) Release flink-connector-rabbitmq v3.1.0 for Flink 1.19

[ https://issues.apache.org/jira/browse/FLINK-35142?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer updated FLINK-35142: -- Summary: Release flink-connector-rabbitmq v3.1.0 for Flink 1.19 (was: Release flink-connector

[jira] [Updated] (FLINK-35174) Bump org.apache.commons:commons-compress from 1.24.0 to 1.26.1 for Flink RabbitMQ connector

[ https://issues.apache.org/jira/browse/FLINK-35174?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer updated FLINK-35174: -- Description: Bump org.apache.commons:commons-compress from 1.24.0 to 1.26.1 for Flink RabbitM

[jira] [Updated] (FLINK-35174) Bump org.apache.commons:commons-compress from 1.24.0 to 1.26.1 for Flink RabbitMQ connector

[ https://issues.apache.org/jira/browse/FLINK-35174?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer updated FLINK-35174: -- Fix Version/s: rabbitmq-3.1.0 (was: aws-connector-4.3.0) > Bump org.apa

[jira] [Updated] (FLINK-35174) Bump org.apache.commons:commons-compress from 1.24.0 to 1.26.1 for Flink RabbitMQ connector

[ https://issues.apache.org/jira/browse/FLINK-35174?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer updated FLINK-35174: -- Component/s: Connectors/ RabbitMQ (was: Connectors / AWS) > Bump org.apac

[jira] [Updated] (FLINK-35174) Bump org.apache.commons:commons-compress from 1.24.0 to 1.26.1 for Flink RabbitMQ connector

[ https://issues.apache.org/jira/browse/FLINK-35174?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer updated FLINK-35174: -- Summary: Bump org.apache.commons:commons-compress from 1.24.0 to 1.26.1 for Flink RabbitMQ con

[jira] [Updated] (FLINK-35142) Release flink-connector-rabbitmq v3.1.0 for Flink 1.19

[ https://issues.apache.org/jira/browse/FLINK-35142?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer updated FLINK-35142: -- Fix Version/s: rabbitmq-3.1.0 > Release flink-connector-rabbitmq v3.1.0 for Flink 1.19 > -

[jira] [Created] (FLINK-35174) Bump org.apache.commons:commons-compress from 1.25.0 to 1.26.1 for Flink RabbitMQ connector

Danny Cranmer created FLINK-35174: - Summary: Bump org.apache.commons:commons-compress from 1.25.0 to 1.26.1 for Flink RabbitMQ connector Key: FLINK-35174 URL: https://issues.apache.org/jira/browse/FLINK-35174

[jira] [Assigned] (FLINK-35142) Release flink-connector-rabbitmq vX.X.X for Flink 1.19

[ https://issues.apache.org/jira/browse/FLINK-35142?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer reassigned FLINK-35142: - Assignee: Danny Cranmer > Release flink-connector-rabbitmq vX.X.X for Flink 1.19 >

[jira] [Commented] (FLINK-34954) Kryo input implementation NoFetchingInput fails to handle zero length bytes

[ https://issues.apache.org/jira/browse/FLINK-34954?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17838937#comment-17838937 ] Danny Cranmer commented on FLINK-34954: --- Thanks for the bug report and fix, [~q.xu

[jira] [Updated] (FLINK-34954) Kryo input implementation NoFetchingInput fails to handle zero length bytes

[ https://issues.apache.org/jira/browse/FLINK-34954?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer updated FLINK-34954: -- Component/s: API / Type Serialization System > Kryo input implementation NoFetchingInput fails

[jira] [Assigned] (FLINK-34954) Kryo input implementation NoFetchingInput fails to handle zero length bytes

[ https://issues.apache.org/jira/browse/FLINK-34954?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer reassigned FLINK-34954: - Assignee: Qinghui Xu > Kryo input implementation NoFetchingInput fails to handle zero l

[jira] [Resolved] (FLINK-34954) Kryo input implementation NoFetchingInput fails to handle zero length bytes

[ https://issues.apache.org/jira/browse/FLINK-34954?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer resolved FLINK-34954. --- Resolution: Fixed > Kryo input implementation NoFetchingInput fails to handle zero length by

[jira] [Updated] (FLINK-34954) Kryo input implementation NoFetchingInput fails to handle zero length bytes

[ https://issues.apache.org/jira/browse/FLINK-34954?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer updated FLINK-34954: -- Fix Version/s: 1.20.0 > Kryo input implementation NoFetchingInput fails to handle zero length

[jira] [Commented] (FLINK-34954) Kryo input implementation NoFetchingInput fails to handle zero length bytes

[ https://issues.apache.org/jira/browse/FLINK-34954?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17838938#comment-17838938 ] Danny Cranmer commented on FLINK-34954: --- Merged commit [{{3977982}}|https://githu

[jira] [Updated] (FLINK-34954) Kryo input implementation NoFetchingInput fails to handle zero length bytes

[ https://issues.apache.org/jira/browse/FLINK-34954?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer updated FLINK-34954: -- Affects Version/s: 1.19.0 > Kryo input implementation NoFetchingInput fails to handle zero len

[jira] [Resolved] (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:all-tabpanel ] Danny Cranmer resolved FLINK-35115. --- Resolution: Fixed > Kinesis connector writes wrong Kinesis sequence number at stop with save

[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&focusedCommentId=17838934#comment-17838934 ] Danny Cranmer commented on FLINK-35115: --- Merged commit [{{8d29147}}|https://githu

[jira] [Updated] (FLINK-35133) Release flink-connector-cassandra v3.2.0 for Flink 1.19

[ https://issues.apache.org/jira/browse/FLINK-35133?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer updated FLINK-35133: -- Summary: Release flink-connector-cassandra v3.2.0 for Flink 1.19 (was: Release flink-connecto

[jira] [Updated] (FLINK-31698) Cassandra nightly CI failure

[ https://issues.apache.org/jira/browse/FLINK-31698?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer updated FLINK-31698: -- Fix Version/s: cassandra-3.2.0 > Cassandra nightly CI failure > >

[jira] [Updated] (FLINK-31749) The Using Hadoop OutputFormats example is not avaliable for DataStream

[ https://issues.apache.org/jira/browse/FLINK-31749?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer updated FLINK-31749: -- Fix Version/s: cassandra-3.2.0 > The Using Hadoop OutputFormats example is not avaliable for D

[jira] [Updated] (FLINK-31807) Test architecture tests don't cover all test code

[ https://issues.apache.org/jira/browse/FLINK-31807?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer updated FLINK-31807: -- Fix Version/s: cassandra-3.2.0 (was: cassandra-4.0.0) > Test architectu

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

[ 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: cassandra-3.2.0 (was: cassandra-4.0.0) > Connector weekl

[jira] [Updated] (FLINK-32014) Cassandra source documentation is missing and javadoc is out of sync

[ https://issues.apache.org/jira/browse/FLINK-32014?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer updated FLINK-32014: -- Fix Version/s: cassandra-3.2.0 > Cassandra source documentation is missing and javadoc is out

[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&focusedCommentId=17838884#comment-17838884 ] Danny Cranmer edited comment on FLINK-35115 at 4/19/24 7:04 AM: --

[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&focusedCommentId=17838884#comment-17838884 ] Danny Cranmer commented on FLINK-35115: --- [~vadim.vararu] yes it will. 4.3.0 will s

[jira] [Commented] (FLINK-35139) Release flink-connector-mongodb v1.2.0 for Flink 1.19

[ https://issues.apache.org/jira/browse/FLINK-35139?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17838592#comment-17838592 ] Danny Cranmer commented on FLINK-35139: --- https://lists.apache.org/thread/2982v6n5q

[jira] [Assigned] (FLINK-35133) Release flink-connector-cassandra v3.x.x for Flink 1.19

[ https://issues.apache.org/jira/browse/FLINK-35133?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer reassigned FLINK-35133: - Assignee: Danny Cranmer > Release flink-connector-cassandra v3.x.x for Flink 1.19 > ---

[jira] [Commented] (FLINK-35135) Release flink-connector-gcp-pubsub v3.1.0 for Flink 1.19

[ https://issues.apache.org/jira/browse/FLINK-35135?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17838590#comment-17838590 ] Danny Cranmer commented on FLINK-35135: --- https://lists.apache.org/thread/b7l1r0y7n

  1   2   3   4   5   6   7   8   9   10   >