Commits

Branch selector

 main

User selector

gguptp

All time

Commit History

Commits on Jan 22, 2026

• [FLINK-38952] Update PyFlink connector classes to match with the current Java API and entities

  gguptp

  authored
  2a9620b

  Copy full SHA for 2a9620b

Commits on Dec 11, 2025

• [FLINK-36296] Add support for incremental shard discovery for DynamoDB Streams Source

  gguptp

  authored
  68acdbd

  Copy full SHA for 68acdbd

Commits on Mar 26, 2025

• [FLINK-37416][BugFix][Connectors/DynamoDB] Fix state inconsistency issue in DDB connector when sending split finished event from reader -> enumerator

  

  gguptp

  authored and

  hlteoh37

  committed
  ca96d84

  Copy full SHA for ca96d84

Commits on Mar 7, 2025

• [FLINK-36203][Connectors/DynamoDB] Added polling delay between getrecords calls for DDB connector

  

  gguptp

  authored and

  hlteoh37

  committed
  8b09b33

  Copy full SHA for 8b09b33

Commits on Oct 24, 2024

• [FLINK-36523][Connectors/DynamoDB][BugFix] Fixing LATEST behaviour for DDB connector

  

  gguptp

  authored and

  hlteoh37

  committed
  52870f1

  Copy full SHA for 52870f1

Commits on Sep 24, 2024

• [FLINK-36329][Connectors/DynamoDB] Changing retry strategy to use SDK retries to catch all retryable exceptions

  

  gguptp

  authored and

  hlteoh37

  committed
  c525e9a

  Copy full SHA for c525e9a

Commits on Sep 19, 2024

• [FLINK-36328][Connectors/DynamoDB] Making the child split not found as a debug log instead of warn

  

  gguptp

  authored and

  hlteoh37

  committed
  3a0e4f5

  Copy full SHA for 3a0e4f5

Commits on Sep 13, 2024

• [FLINK-36270][Connectors/DynamoDB] Assign only children splits of a split when it is marked as finished

  

  gguptp

  authored and

  hlteoh37

  committed
  9b0d983

  Copy full SHA for 9b0d983

Commits on Sep 9, 2024

• [FLINK-36239][Connectors/DynamoDB][BugFix] Making the shard retention period to 48h instead of 24h

  

  gguptp

  authored and

  hlteoh37

  committed
  876892d

  Copy full SHA for 876892d

Commits on Sep 4, 2024

• [FLINK-36206][Connectors/AWS] Adding support for custom override configuration

  

  gguptp

  authored and

  hlteoh37

  committed
  4604d66

  Copy full SHA for 4604d66

• [FLINK-36215][dynamodb][BugFix] Removing dependency on ordering of splits

  

  gguptp

  authored and

  hlteoh37

  committed
  4d847fe

  Copy full SHA for 4d847fe

Commits on Sep 3, 2024

• [FLINK-35660][dynamodb] Adding parent-child shard ordering for DDB Streams source and add MillisBehindLatest metric

  

  gguptp

  authored and

  hlteoh37

  committed
  18ff2d2

  Copy full SHA for 18ff2d2

Commits on Jul 10, 2024

• [FLINK-34341] Initial implementation of DynamoDBStreams Source. Marked as Experimental

  

  gguptp

  authored and

  hlteoh37

  committed
  7f3483c

  Copy full SHA for 7f3483c