[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] [Created] (FLINK-35141) Release flink-connector-pulsar vX.X.X for Flink 1.19

Danny Cranmer created FLINK-35141: - Summary: Release flink-connector-pulsar vX.X.X for Flink 1.19 Key: FLINK-35141 URL: https://issues.apache.org/jira/browse/FLINK-35141 Project: Flink Issue

[jira] [Created] (FLINK-35134) Release flink-connector-elasticsearch vX.X.X for Flink 1.18/1.19

Danny Cranmer created FLINK-35134: - Summary: Release flink-connector-elasticsearch vX.X.X for Flink 1.18/1.19 Key: FLINK-35134 URL: https://issues.apache.org/jira/browse/FLINK-35134 Project: Flink

[jira] [Created] (FLINK-35136) Release flink-connector-hbase vX.X.X for Flink 1.19

Danny Cranmer created FLINK-35136: - Summary: Release flink-connector-hbase vX.X.X for Flink 1.19 Key: FLINK-35136 URL: https://issues.apache.org/jira/browse/FLINK-35136 Project: Flink Issue

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

Danny Cranmer created FLINK-35142: - Summary: Release flink-connector-rabbitmq vX.X.X for Flink 1.19 Key: FLINK-35142 URL: https://issues.apache.org/jira/browse/FLINK-35142 Project: Flink

[jira] [Created] (FLINK-35140) Release flink-connector-opensearch vX.X.X for Flink 1.19

Danny Cranmer created FLINK-35140: - Summary: Release flink-connector-opensearch vX.X.X for Flink 1.19 Key: FLINK-35140 URL: https://issues.apache.org/jira/browse/FLINK-35140 Project: Flink

[jira] [Created] (FLINK-35133) Release flink-connector-cassandra v4.3.0 for Flink 1.18/1.19

Danny Cranmer created FLINK-35133: - Summary: Release flink-connector-cassandra v4.3.0 for Flink 1.18/1.19 Key: FLINK-35133 URL: https://issues.apache.org/jira/browse/FLINK-35133 Project: Flink

[jira] [Created] (FLINK-35139) Release flink-connector-mongodb vX.X.X for Flink 1.19

Danny Cranmer created FLINK-35139: - Summary: Release flink-connector-mongodb vX.X.X for Flink 1.19 Key: FLINK-35139 URL: https://issues.apache.org/jira/browse/FLINK-35139 Project: Flink

[jira] [Created] (FLINK-35138) Release flink-connector-kafka vX.X.X for Flink 1.19

Danny Cranmer created FLINK-35138: - Summary: Release flink-connector-kafka vX.X.X for Flink 1.19 Key: FLINK-35138 URL: https://issues.apache.org/jira/browse/FLINK-35138 Project: Flink Issue

[jira] [Created] (FLINK-35137) Release flink-connector-jdbc vX.X.X for Flink 1.19

Danny Cranmer created FLINK-35137: - Summary: Release flink-connector-jdbc vX.X.X for Flink 1.19 Key: FLINK-35137 URL: https://issues.apache.org/jira/browse/FLINK-35137 Project: Flink Issue

[jira] [Created] (FLINK-35135) Release flink-connector-gcp-pubsub vX.X.X for Flink 1.18/1.19

Danny Cranmer created FLINK-35135: - Summary: Release flink-connector-gcp-pubsub vX.X.X for Flink 1.18/1.19 Key: FLINK-35135 URL: https://issues.apache.org/jira/browse/FLINK-35135 Project: Flink

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

Danny Cranmer created FLINK-35132: - Summary: Release flink-connector-aws v4.3.0 for Flink 1.18/1.19 Key: FLINK-35132 URL: https://issues.apache.org/jira/browse/FLINK-35132 Project: Flink

[jira] [Created] (FLINK-35131) Support and Release Connectors for Flink 1.19

Danny Cranmer created FLINK-35131: - Summary: Support and Release Connectors for Flink 1.19 Key: FLINK-35131 URL: https://issues.apache.org/jira/browse/FLINK-35131 Project: Flink Issue Type:

[jira] [Created] (FLINK-35124) Connector Release Fails to run Checkstyle

Danny Cranmer created FLINK-35124: - Summary: Connector Release Fails to run Checkstyle Key: FLINK-35124 URL: https://issues.apache.org/jira/browse/FLINK-35124 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-35113) Bump org.apache.commons:commons-compress from 1.25.0 to 1.26.1 for Flink AWS connectors

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

[jira] [Created] (FLINK-34342) Address ListShards Consistency for DDB Streams Source

Danny Cranmer created FLINK-34342: - Summary: Address ListShards Consistency for DDB Streams Source Key: FLINK-34342 URL: https://issues.apache.org/jira/browse/FLINK-34342 Project: Flink

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

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:

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

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] [Created] (FLINK-34339) Add connector abstraction layer to remove reliance on AWWS SDK classes

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:

[jira] [Created] (FLINK-34024) Update connector release process for Python connectors

Danny Cranmer created FLINK-34024: - Summary: Update connector release process for Python connectors Key: FLINK-34024 URL: https://issues.apache.org/jira/browse/FLINK-34024 Project: Flink

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

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

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

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

[jira] [Created] (FLINK-33279) KinesisStream e2e test failing on PR during cleanup

Danny Cranmer created FLINK-33279: - Summary: KinesisStream e2e test failing on PR during cleanup Key: FLINK-33279 URL: https://issues.apache.org/jira/browse/FLINK-33279 Project: Flink Issue

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

Danny Cranmer created FLINK-33260: - Summary: Custom Error Handling for Kinesis Consumer Key: FLINK-33260 URL: https://issues.apache.org/jira/browse/FLINK-33260 Project: Flink Issue Type:

[jira] [Created] (FLINK-33151) Prometheus Sink Connector - Create Github Repo

Danny Cranmer created FLINK-33151: - Summary: Prometheus Sink Connector - Create Github Repo Key: FLINK-33151 URL: https://issues.apache.org/jira/browse/FLINK-33151 Project: Flink Issue Type:

[jira] [Created] (FLINK-33048) Project website refresh Light Mode

Danny Cranmer created FLINK-33048: - Summary: Project website refresh Light Mode Key: FLINK-33048 URL: https://issues.apache.org/jira/browse/FLINK-33048 Project: Flink Issue Type: Sub-task

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

Danny Cranmer created FLINK-33049: - Summary: Project website refresh Code Samples Widget Key: FLINK-33049 URL: https://issues.apache.org/jira/browse/FLINK-33049 Project: Flink Issue Type:

[jira] [Created] (FLINK-33047) Project website refresh Dark Mode

Danny Cranmer created FLINK-33047: - Summary: Project website refresh Dark Mode Key: FLINK-33047 URL: https://issues.apache.org/jira/browse/FLINK-33047 Project: Flink Issue Type: Sub-task

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

Danny Cranmer created FLINK-33046: - Summary: [FLIP-333] Redesign Apache Flink website Key: FLINK-33046 URL: https://issues.apache.org/jira/browse/FLINK-33046 Project: Flink Issue Type: New

[jira] [Created] (FLINK-33043) Search is broken on the Flink website

Danny Cranmer created FLINK-33043: - Summary: Search is broken on the Flink website Key: FLINK-33043 URL: https://issues.apache.org/jira/browse/FLINK-33043 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-31918) Pulsar Source does not failing build against Flink 1.18 on nightly CI

Danny Cranmer created FLINK-31918: - Summary: Pulsar Source does not failing build against Flink 1.18 on nightly CI Key: FLINK-31918 URL: https://issues.apache.org/jira/browse/FLINK-31918 Project:

[jira] [Created] (FLINK-31847) Flink Connector JDBC CI Failing

Danny Cranmer created FLINK-31847: - Summary: Flink Connector JDBC CI Failing Key: FLINK-31847 URL: https://issues.apache.org/jira/browse/FLINK-31847 Project: Flink Issue Type: Technical

[jira] [Created] (FLINK-31793) Remove dependency on flink-shaded for flink-connector-jdbc

Danny Cranmer created FLINK-31793: - Summary: Remove dependency on flink-shaded for flink-connector-jdbc Key: FLINK-31793 URL: https://issues.apache.org/jira/browse/FLINK-31793 Project: Flink

[jira] [Created] (FLINK-31704) Pulsar docs should be pulled from dedicated branch

Danny Cranmer created FLINK-31704: - Summary: Pulsar docs should be pulled from dedicated branch Key: FLINK-31704 URL: https://issues.apache.org/jira/browse/FLINK-31704 Project: Flink Issue

[jira] [Created] (FLINK-31703) Update Flink docs for AWS v4.1.0

Danny Cranmer created FLINK-31703: - Summary: Update Flink docs for AWS v4.1.0 Key: FLINK-31703 URL: https://issues.apache.org/jira/browse/FLINK-31703 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-31702) Integrate Opensearch connector docs into Flink docs v1.17/master

Danny Cranmer created FLINK-31702: - Summary: Integrate Opensearch connector docs into Flink docs v1.17/master Key: FLINK-31702 URL: https://issues.apache.org/jira/browse/FLINK-31702 Project: Flink

[jira] [Created] (FLINK-31701) RabbitMQ nightly CI failure

Danny Cranmer created FLINK-31701: - Summary: RabbitMQ nightly CI failure Key: FLINK-31701 URL: https://issues.apache.org/jira/browse/FLINK-31701 Project: Flink Issue Type: Technical Debt

[jira] [Created] (FLINK-31700) MongoDB nightly CI failure

Danny Cranmer created FLINK-31700: - Summary: MongoDB nightly CI failure Key: FLINK-31700 URL: https://issues.apache.org/jira/browse/FLINK-31700 Project: Flink Issue Type: Technical Debt

[jira] [Created] (FLINK-31699) JDBC nightly CI failure

Danny Cranmer created FLINK-31699: - Summary: JDBC nightly CI failure Key: FLINK-31699 URL: https://issues.apache.org/jira/browse/FLINK-31699 Project: Flink Issue Type: Technical Debt

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

Danny Cranmer created FLINK-31698: - Summary: Cassandra nightly CI failure Key: FLINK-31698 URL: https://issues.apache.org/jira/browse/FLINK-31698 Project: Flink Issue Type: Technical Debt

[jira] [Created] (FLINK-31697) OpenSearch nightly CI failure

Danny Cranmer created FLINK-31697: - Summary: OpenSearch nightly CI failure Key: FLINK-31697 URL: https://issues.apache.org/jira/browse/FLINK-31697 Project: Flink Issue Type: Technical Debt

[jira] [Created] (FLINK-31696) ElasticSearch nightly CI failure

Danny Cranmer created FLINK-31696: - Summary: ElasticSearch nightly CI failure Key: FLINK-31696 URL: https://issues.apache.org/jira/browse/FLINK-31696 Project: Flink Issue Type: Technical

[jira] [Created] (FLINK-31692) Integrate MongoDB connector docs into Flink website

Danny Cranmer created FLINK-31692: - Summary: Integrate MongoDB connector docs into Flink website Key: FLINK-31692 URL: https://issues.apache.org/jira/browse/FLINK-31692 Project: Flink Issue

[jira] [Created] (FLINK-31183) Flink Kinesis EFO Consumer can fail to stop gracefully

Danny Cranmer created FLINK-31183: - Summary: Flink Kinesis EFO Consumer can fail to stop gracefully Key: FLINK-31183 URL: https://issues.apache.org/jira/browse/FLINK-31183 Project: Flink

[jira] [Created] (FLINK-31041) Race condition in DefaultScheduler results in memory leak and busy loop

Danny Cranmer created FLINK-31041: - Summary: Race condition in DefaultScheduler results in memory leak and busy loop Key: FLINK-31041 URL: https://issues.apache.org/jira/browse/FLINK-31041 Project:

[jira] [Created] (FLINK-30633) Update AWS SDKv2 to v2.19.14

Danny Cranmer created FLINK-30633: - Summary: Update AWS SDKv2 to v2.19.14 Key: FLINK-30633 URL: https://issues.apache.org/jira/browse/FLINK-30633 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-30557) Remove flink-connector-aws-kinesis-streams from Flink master branch

Danny Cranmer created FLINK-30557: - Summary: Remove flink-connector-aws-kinesis-streams from Flink master branch Key: FLINK-30557 URL: https://issues.apache.org/jira/browse/FLINK-30557 Project: Flink

[jira] [Created] (FLINK-30550) Flink master to integrate KDS/KDF docs from flink-connector-aws

Danny Cranmer created FLINK-30550: - Summary: Flink master to integrate KDS/KDF docs from flink-connector-aws Key: FLINK-30550 URL: https://issues.apache.org/jira/browse/FLINK-30550 Project: Flink

[jira] [Created] (FLINK-30549) Remove flink-connector-firehose from Flink master branch

Danny Cranmer created FLINK-30549: - Summary: Remove flink-connector-firehose from Flink master branch Key: FLINK-30549 URL: https://issues.apache.org/jira/browse/FLINK-30549 Project: Flink

[jira] [Created] (FLINK-30436) Integrate Opensearch connector docs into Flink docs v1.16

Danny Cranmer created FLINK-30436: - Summary: Integrate Opensearch connector docs into Flink docs v1.16 Key: FLINK-30436 URL: https://issues.apache.org/jira/browse/FLINK-30436 Project: Flink

[jira] [Created] (FLINK-30388) Add support for ElementConverted open() method for KDS/KDF/DDB

Danny Cranmer created FLINK-30388: - Summary: Add support for ElementConverted open() method for KDS/KDF/DDB Key: FLINK-30388 URL: https://issues.apache.org/jira/browse/FLINK-30388 Project: Flink

[jira] [Created] (FLINK-30385) Remove KDS/KDF/AWS Base connectors from master branch

Danny Cranmer created FLINK-30385: - Summary: Remove KDS/KDF/AWS Base connectors from master branch Key: FLINK-30385 URL: https://issues.apache.org/jira/browse/FLINK-30385 Project: Flink

[jira] [Created] (FLINK-30384) Sync master KDS/KDF connector changes to flink-connector-aws

Danny Cranmer created FLINK-30384: - Summary: Sync master KDS/KDF connector changes to flink-connector-aws Key: FLINK-30384 URL: https://issues.apache.org/jira/browse/FLINK-30384 Project: Flink

[jira] [Created] (FLINK-30382) Flink 1.16 to integrate KDS/KDF docs from flink-connector-aws

Danny Cranmer created FLINK-30382: - Summary: Flink 1.16 to integrate KDS/KDF docs from flink-connector-aws Key: FLINK-30382 URL: https://issues.apache.org/jira/browse/FLINK-30382 Project: Flink

[jira] [Created] (FLINK-30356) Update NOTICE files to say "Apache Flink AWS connectors"

Danny Cranmer created FLINK-30356: - Summary: Update NOTICE files to say "Apache Flink AWS connectors" Key: FLINK-30356 URL: https://issues.apache.org/jira/browse/FLINK-30356 Project: Flink

[jira] [Created] (FLINK-30304) Possible Deadlock in Kinesis/Firehose/DynamoDB Connector

Danny Cranmer created FLINK-30304: - Summary: Possible Deadlock in Kinesis/Firehose/DynamoDB Connector Key: FLINK-30304 URL: https://issues.apache.org/jira/browse/FLINK-30304 Project: Flink

[jira] [Created] (FLINK-30291) Integrate flink-connector-aws into Flink docs

Danny Cranmer created FLINK-30291: - Summary: Integrate flink-connector-aws into Flink docs Key: FLINK-30291 URL: https://issues.apache.org/jira/browse/FLINK-30291 Project: Flink Issue Type:

[jira] [Created] (FLINK-30230) Drop Support for Flink 1.15

Danny Cranmer created FLINK-30230: - Summary: Drop Support for Flink 1.15 Key: FLINK-30230 URL: https://issues.apache.org/jira/browse/FLINK-30230 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-30229) SQL IT case for DynamoDB Sink

Danny Cranmer created FLINK-30229: - Summary: SQL IT case for DynamoDB Sink Key: FLINK-30229 URL: https://issues.apache.org/jira/browse/FLINK-30229 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-30008) Add Flink 1.16.0 Support

Danny Cranmer created FLINK-30008: - Summary: Add Flink 1.16.0 Support Key: FLINK-30008 URL: https://issues.apache.org/jira/browse/FLINK-30008 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-29960) Update README to Reflect AWS Connectors Single Repo

Danny Cranmer created FLINK-29960: - Summary: Update README to Reflect AWS Connectors Single Repo Key: FLINK-29960 URL: https://issues.apache.org/jira/browse/FLINK-29960 Project: Flink Issue

[jira] [Created] (FLINK-29954) Improve DynamoDB Connector Sample Code

Danny Cranmer created FLINK-29954: - Summary: Improve DynamoDB Connector Sample Code Key: FLINK-29954 URL: https://issues.apache.org/jira/browse/FLINK-29954 Project: Flink Issue Type:

[jira] [Created] (FLINK-29938) Add open() Method to AsyncSink ElementConverter

Danny Cranmer created FLINK-29938: - Summary: Add open() Method to AsyncSink ElementConverter Key: FLINK-29938 URL: https://issues.apache.org/jira/browse/FLINK-29938 Project: Flink Issue

[jira] [Created] (FLINK-29937) Enhanced DynamoDB Element Converter

Danny Cranmer created FLINK-29937: - Summary: Enhanced DynamoDB Element Converter Key: FLINK-29937 URL: https://issues.apache.org/jira/browse/FLINK-29937 Project: Flink Issue Type:

[jira] [Created] (FLINK-29908) Externalize and configure E2E tests

Danny Cranmer created FLINK-29908: - Summary: Externalize and configure E2E tests Key: FLINK-29908 URL: https://issues.apache.org/jira/browse/FLINK-29908 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-29907) Externalize AWS connectors from Flink core

Danny Cranmer created FLINK-29907: - Summary: Externalize AWS connectors from Flink core Key: FLINK-29907 URL: https://issues.apache.org/jira/browse/FLINK-29907 Project: Flink Issue Type:

[jira] [Created] (FLINK-29906) Address tabs/spaces in checkstyle/spotless

Danny Cranmer created FLINK-29906: - Summary: Address tabs/spaces in checkstyle/spotless Key: FLINK-29906 URL: https://issues.apache.org/jira/browse/FLINK-29906 Project: Flink Issue Type:

[jira] [Created] (FLINK-29905) Migrate flink-connector-dynamodb-parent to flink-connector-aws-parent

Danny Cranmer created FLINK-29905: - Summary: Migrate flink-connector-dynamodb-parent to flink-connector-aws-parent Key: FLINK-29905 URL: https://issues.apache.org/jira/browse/FLINK-29905 Project:

[jira] [Created] (FLINK-29896) DynamoDB CI Failing to run checks

Danny Cranmer created FLINK-29896: - Summary: DynamoDB CI Failing to run checks Key: FLINK-29896 URL: https://issues.apache.org/jira/browse/FLINK-29896 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-29894) Rename flink-connector-dynamodb to flink-connector-aws

Danny Cranmer created FLINK-29894: - Summary: Rename flink-connector-dynamodb to flink-connector-aws Key: FLINK-29894 URL: https://issues.apache.org/jira/browse/FLINK-29894 Project: Flink

[jira] [Created] (FLINK-29854) Make Record Size Flush Strategy Optional for Async Sink

Danny Cranmer created FLINK-29854: - Summary: Make Record Size Flush Strategy Optional for Async Sink Key: FLINK-29854 URL: https://issues.apache.org/jira/browse/FLINK-29854 Project: Flink

[jira] [Created] (FLINK-29688) Build time compatibility check for DynamoDB SDK

Danny Cranmer created FLINK-29688: - Summary: Build time compatibility check for DynamoDB SDK Key: FLINK-29688 URL: https://issues.apache.org/jira/browse/FLINK-29688 Project: Flink Issue

[jira] [Created] (FLINK-29444) Setup release scripts

Danny Cranmer created FLINK-29444: - Summary: Setup release scripts Key: FLINK-29444 URL: https://issues.apache.org/jira/browse/FLINK-29444 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-29443) Replicate packaging tests

Danny Cranmer created FLINK-29443: - Summary: Replicate packaging tests Key: FLINK-29443 URL: https://issues.apache.org/jira/browse/FLINK-29443 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-29442) Setup license checks

Danny Cranmer created FLINK-29442: - Summary: Setup license checks Key: FLINK-29442 URL: https://issues.apache.org/jira/browse/FLINK-29442 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-29441) Setup dependency convergence check

Danny Cranmer created FLINK-29441: - Summary: Setup dependency convergence check Key: FLINK-29441 URL: https://issues.apache.org/jira/browse/FLINK-29441 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-29440) Setup CI Logging

Danny Cranmer created FLINK-29440: - Summary: Setup CI Logging Key: FLINK-29440 URL: https://issues.apache.org/jira/browse/FLINK-29440 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-29439) Add DynamoDB project readme

Danny Cranmer created FLINK-29439: - Summary: Add DynamoDB project readme Key: FLINK-29439 URL: https://issues.apache.org/jira/browse/FLINK-29439 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-29438) Setup DynamoDB Connector Project Structure

Danny Cranmer created FLINK-29438: - Summary: Setup DynamoDB Connector Project Structure Key: FLINK-29438 URL: https://issues.apache.org/jira/browse/FLINK-29438 Project: Flink Issue Type:

[jira] [Created] (FLINK-29246) Setup DynamoDB Connector Project Structure

Danny Cranmer created FLINK-29246: - Summary: Setup DynamoDB Connector Project Structure Key: FLINK-29246 URL: https://issues.apache.org/jira/browse/FLINK-29246 Project: Flink Issue Type:

[jira] [Created] (FLINK-29205) FlinkKinesisConsumer not respecting Credential Provider configuration for EFO

Danny Cranmer created FLINK-29205: - Summary: FlinkKinesisConsumer not respecting Credential Provider configuration for EFO Key: FLINK-29205 URL: https://issues.apache.org/jira/browse/FLINK-29205

[jira] [Created] (FLINK-28094) [aws][Kinesis][Firehose] Upgrade AWS SDK to support ap-southeast-3

Danny Cranmer created FLINK-28094: - Summary: [aws][Kinesis][Firehose] Upgrade AWS SDK to support ap-southeast-3 Key: FLINK-28094 URL: https://issues.apache.org/jira/browse/FLINK-28094 Project: Flink

[jira] [Created] (FLINK-26890) [Kinesis][Consumer] DynamoDB consumer error consuming partitions close to retention

Danny Cranmer created FLINK-26890: - Summary: [Kinesis][Consumer] DynamoDB consumer error consuming partitions close to retention Key: FLINK-26890 URL: https://issues.apache.org/jira/browse/FLINK-26890

[jira] [Created] (FLINK-26417) Async can Sink violate At Least Once during checkpointing

Danny Cranmer created FLINK-26417: - Summary: Async can Sink violate At Least Once during checkpointing Key: FLINK-26417 URL: https://issues.apache.org/jira/browse/FLINK-26417 Project: Flink

[jira] [Created] (FLINK-26008) [FLIP-171] Update Kinesalite docker container reference

Danny Cranmer created FLINK-26008: - Summary: [FLIP-171] Update Kinesalite docker container reference Key: FLINK-26008 URL: https://issues.apache.org/jira/browse/FLINK-26008 Project: Flink

[jira] [Created] (FLINK-25848) [FLIP-171] KDS Sink does not fast fail when invalid configuration supplied

Danny Cranmer created FLINK-25848: - Summary: [FLIP-171] KDS Sink does not fast fail when invalid configuration supplied Key: FLINK-25848 URL: https://issues.apache.org/jira/browse/FLINK-25848

[jira] [Created] (FLINK-25846) Async Sink does not gracefully shutdown on Cancel

Danny Cranmer created FLINK-25846: - Summary: Async Sink does not gracefully shutdown on Cancel Key: FLINK-25846 URL: https://issues.apache.org/jira/browse/FLINK-25846 Project: Flink Issue

[jira] [Created] (FLINK-24431) [Kinesis][EFO] EAGER registration strategy does not work when job fails over

Danny Cranmer created FLINK-24431: - Summary: [Kinesis][EFO] EAGER registration strategy does not work when job fails over Key: FLINK-24431 URL: https://issues.apache.org/jira/browse/FLINK-24431

[jira] [Created] (FLINK-23996) Make Scala 2.12 default build target

Danny Cranmer created FLINK-23996: - Summary: Make Scala 2.12 default build target Key: FLINK-23996 URL: https://issues.apache.org/jira/browse/FLINK-23996 Project: Flink Issue Type:

[jira] [Created] (FLINK-23802) [kinesis][efo] Reduce ReadTimeoutExceptions for Kinesis Consumer

Danny Cranmer created FLINK-23802: - Summary: [kinesis][efo] Reduce ReadTimeoutExceptions for Kinesis Consumer Key: FLINK-23802 URL: https://issues.apache.org/jira/browse/FLINK-23802 Project: Flink

[jira] [Created] (FLINK-21933) [kinesis][efo] EFO consumer treats interrupts as retryable exceptions

Danny Cranmer created FLINK-21933: - Summary: [kinesis][efo] EFO consumer treats interrupts as retryable exceptions Key: FLINK-21933 URL: https://issues.apache.org/jira/browse/FLINK-21933 Project:

[jira] [Created] (FLINK-21830) [kinesis][auth] Add support for Session Token

Danny Cranmer created FLINK-21830: - Summary: [kinesis][auth] Add support for Session Token Key: FLINK-21830 URL: https://issues.apache.org/jira/browse/FLINK-21830 Project: Flink Issue Type:

[jira] [Created] (FLINK-21391) Migrate AWS Glue e2e test from sh to Java

Danny Cranmer created FLINK-21391: - Summary: Migrate AWS Glue e2e test from sh to Java Key: FLINK-21391 URL: https://issues.apache.org/jira/browse/FLINK-21391 Project: Flink Issue Type:

[jira] [Created] (FLINK-21228) [Kinesis][Producer] Deadlock in KinesisProducer

Danny Cranmer created FLINK-21228: - Summary: [Kinesis][Producer] Deadlock in KinesisProducer Key: FLINK-21228 URL: https://issues.apache.org/jira/browse/FLINK-21228 Project: Flink Issue

[jira] [Created] (FLINK-20630) [Kinesis][DynamoDB] DynamoDB Consumer fails to consume from Latest

Danny Cranmer created FLINK-20630: - Summary: [Kinesis][DynamoDB] DynamoDB Consumer fails to consume from Latest Key: FLINK-20630 URL: https://issues.apache.org/jira/browse/FLINK-20630 Project: Flink

[jira] [Created] (FLINK-20629) [Kinesis][EFO] Migrate from DescribeStream to DescribeStreamSummary

Danny Cranmer created FLINK-20629: - Summary: [Kinesis][EFO] Migrate from DescribeStream to DescribeStreamSummary Key: FLINK-20629 URL: https://issues.apache.org/jira/browse/FLINK-20629 Project: Flink

[jira] [Created] (FLINK-20350) [Kinesis][GCP PubSub] Incompatible Connectors due to Guava conflict

Danny Cranmer created FLINK-20350: - Summary: [Kinesis][GCP PubSub] Incompatible Connectors due to Guava conflict Key: FLINK-20350 URL: https://issues.apache.org/jira/browse/FLINK-20350 Project: Flink

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

Danny Cranmer created FLINK-20088: - Summary: [Kinesis][Polling] Issue using Polling consumer at timestamp with empty shard Key: FLINK-20088 URL: https://issues.apache.org/jira/browse/FLINK-20088

[jira] [Created] (FLINK-19899) [Kinesis][EFO] Optimise error handling to use a separate exception delivery mechanism

Danny Cranmer created FLINK-19899: - Summary: [Kinesis][EFO] Optimise error handling to use a separate exception delivery mechanism Key: FLINK-19899 URL: https://issues.apache.org/jira/browse/FLINK-19899

[jira] [Created] (FLINK-19898) [Kinesis][EFO] Ignore ReadTimeoutException from SubcribeToShard retry policy

Danny Cranmer created FLINK-19898: - Summary: [Kinesis][EFO] Ignore ReadTimeoutException from SubcribeToShard retry policy Key: FLINK-19898 URL: https://issues.apache.org/jira/browse/FLINK-19898

  1   2   >