flink-connector-aws

flink-connector-aws copied to clipboard

## Purpose of the change - Implements parent-child shard ordering in DDB Streams source - Source enumerator will only assign splits that correspond to a shard when parent shard is...

gguptp

## Purpose of the change Port over Kinesis Client configurations for retry and backoff ## Verifying this change - *Added unit tests* ## Significant changes *(Please check any boxes [x]...

karubian

[FLINK-36428][Connectors/DynamoDB] DynamoDb Table API Sink fails when null value in the RowData

1

## Purpose of the change Add an option `ignore-nulls` to determine whether to ignore null values, instead of [hardcoding](https://github.com/maoxingda/flink-connector-aws/blob/b681cfcd372a44a34c4e6c868cb8a69d50aac67c/flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/table/RowDataToAttributeValueConverter.java#L53) it into the code. ## Verifying this change Please make sure...

maoxingda

## 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...

karubian

[FLINK-35401][Connectors/Sqs] Add Sqs Table API connector

2

## Purpose of the change Implements the Table API for the Sqs Sink Connector. ## Verifying this change - Added unit tests - Manually verified by running the SQS connector...

vahmed-hamdy