flink-connector-aws

flink-connector-aws copied to clipboard

[FLINK-35022][Connector/DynamoDB] Add TypeInformed DDB Element Converter as default element converter

4

## Purpose of the change Add `DynamoDbTypeInformedElementConverter` to convert Elements to dynamoDb Sink using its provided type Info. ## Verifying this change This change added tests and can be verified...

vahmed-hamdy

[FLINK-30481][FLIP-277] GlueCatalog Implementation

26

## Purpose of the change Add Glue catalog feature ## Verifying this change Tested in EMR cluster - Unit test cases ## Significant changes *(Please check any boxes [x] if...

Samrat002

[FLINK-24379][Formats] Avro Glue Schema Registry table format

3

## Purpose of the change Implement Table API support for Avro with AWS Glue Schema Registry ## Verifying this change - Added unit tests - Manually verified by running a...

nicusX

[FLINK-35305](https://issues.apache.org/jira/browse/FLINK-35305)Amazon SQS Sink Connector

1

## Purpose of the change Implements the Amazon SQS Sink Connector ## Verifying this change This change added tests and can be verified as follows: Added unit tests Added integration...

19priyadhingra

[FLINK-35299] Respect initial position for new streams

1

## Purpose of the change According to the javadoc, the `STREAM_INITIAL_POSITION` property defines where to start reading Kinesis streams from. However, in the current implementation this is only true if...

antssilva96

[FLINK-33132] Flink Connector Redshift TableSink Implementation

4

## Purpose of the change Flink Connector Redshift Sink Implementation ## Verifying this change #### JDBC mode testing ``` CREATE TABLE users1 ( > `id` BIGINT, > `data` STRING, >...

Samrat002

## Purpose of the change Implements the Table API for the Kinesis Source. ## Verifying this change This change added tests and can be verified as follows: - *Added unit...

darenwkt

[FLINK-31980] Implement support for EFO in Kinesis consumer

3

## Purpose of the change Implement support for EFO in the new KDS source ## Verifying this change This change added tests and can be verified as follows: - Added...

hlteoh37

[FLINK-31923] Run nightly builds against multiple branches and Flink versions

6

This PR does a couple of things: 1. It syncs this CI workflow to use the shared CI tooling for externalized Flink connectors 907466c0ec253f93500bdda9070cea32f7e808f5 2. It changes the nightly builds...

MartijnVisser

[FLINK-35500][Connectors/DynamoDB] DynamoDb Table API Sink fails to delete elements due to key not found

5

## Purpose of the change When `DynamoDbSink` is used with CDC sources, it fails to process DELETE records and throws ``` org.apache.flink.connector.dynamodb.shaded.software.amazon.awssdk.services.dynamodb.model.DynamoDbException: The provided key element does not match the...

robg-eb