[jira] [Created] (FLINK-37841) Having adaptive retry strategy causing issues in DDB Connector

Abhi Gupta created FLINK-37841: -- Summary: Having adaptive retry strategy causing issues in DDB Connector Key: FLINK-37841 URL: https://issues.apache.org/jira/browse/FLINK-37841 Project: Flink I

[jira] [Created] (FLINK-37563) Add additional metrics for DDB connector

Abhi Gupta created FLINK-37563: -- Summary: Add additional metrics for DDB connector Key: FLINK-37563 URL: https://issues.apache.org/jira/browse/FLINK-37563 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-37416) DDB Streams connector flink state inconsistency issue

Abhi Gupta created FLINK-37416: -- Summary: DDB Streams connector flink state inconsistency issue Key: FLINK-37416 URL: https://issues.apache.org/jira/browse/FLINK-37416 Project: Flink Issue Type:

[jira] [Created] (FLINK-36523) DDB Streams connector treating LATEST as TRIM_HORIZON for some cases

Abhi Gupta created FLINK-36523: -- Summary: DDB Streams connector treating LATEST as TRIM_HORIZON for some cases Key: FLINK-36523 URL: https://issues.apache.org/jira/browse/FLINK-36523 Project: Flink

[jira] [Created] (FLINK-36329) DDB Streams connector not retrying some SDK exceptions

Abhi Gupta created FLINK-36329: -- Summary: DDB Streams connector not retrying some SDK exceptions Key: FLINK-36329 URL: https://issues.apache.org/jira/browse/FLINK-36329 Project: Flink Issue Type

[jira] [Created] (FLINK-36328) Making the log for child not found as debug

Abhi Gupta created FLINK-36328: -- Summary: Making the log for child not found as debug Key: FLINK-36328 URL: https://issues.apache.org/jira/browse/FLINK-36328 Project: Flink Issue Type: Improveme

[jira] [Created] (FLINK-36296) Add incremental shard discovery for DDB Streams source

Abhi Gupta created FLINK-36296: -- Summary: Add incremental shard discovery for DDB Streams source Key: FLINK-36296 URL: https://issues.apache.org/jira/browse/FLINK-36296 Project: Flink Issue Type

[jira] [Created] (FLINK-36270) DDB Streams Connector performance issue due to splitsAvailableForAssignment function

Abhi Gupta created FLINK-36270: -- Summary: DDB Streams Connector performance issue due to splitsAvailableForAssignment function Key: FLINK-36270 URL: https://issues.apache.org/jira/browse/FLINK-36270 Proj

[jira] [Created] (FLINK-36239) DDB Streams Connector reprocessing due to DescribeStream inconsistencies for trimmed shards

Abhi Gupta created FLINK-36239: -- Summary: DDB Streams Connector reprocessing due to DescribeStream inconsistencies for trimmed shards Key: FLINK-36239 URL: https://issues.apache.org/jira/browse/FLINK-36239

[jira] [Created] (FLINK-36206) Support flink-connector-aws-base to allow custom override configuration

Abhi Gupta created FLINK-36206: -- Summary: Support flink-connector-aws-base to allow custom override configuration Key: FLINK-36206 URL: https://issues.apache.org/jira/browse/FLINK-36206 Project: Flink

[jira] [Created] (FLINK-36204) Fix dropping records when consuming from LATEST and having a restore from expired snapshot

Abhi Gupta created FLINK-36204: -- Summary: Fix dropping records when consuming from LATEST and having a restore from expired snapshot Key: FLINK-36204 URL: https://issues.apache.org/jira/browse/FLINK-36204

[jira] [Created] (FLINK-36203) Have some way to control the polling frequency of GetRecords from SplitFetcher

Abhi Gupta created FLINK-36203: -- Summary: Have some way to control the polling frequency of GetRecords from SplitFetcher Key: FLINK-36203 URL: https://issues.apache.org/jira/browse/FLINK-36203 Project: F

[jira] [Created] (FLINK-36196) Have a UX for customer where customer just gives table name and gets the stream arn which is enabled

Abhi Gupta created FLINK-36196: -- Summary: Have a UX for customer where customer just gives table name and gets the stream arn which is enabled Key: FLINK-36196 URL: https://issues.apache.org/jira/browse/FLINK-36196

[jira] [Created] (FLINK-36195) Migrate DDB Streams specific retry configuration to flink-connector-base

Abhi Gupta created FLINK-36195: -- Summary: Migrate DDB Streams specific retry configuration to flink-connector-base Key: FLINK-36195 URL: https://issues.apache.org/jira/browse/FLINK-36195 Project: Flink