Commits

Branch selector

 main

User selector

All users

Datepicker

All time

Commit History

Commits on Dec 15, 2025

• [FLINK-37627] Fix restart from checkpoint/savepoint at shard split can cause data loss

  Show description for 03e2fad
  

  Arun Lakshman

  authored and

  ferenc-csaky

  committed
  03e2fad

  Copy full SHA for 03e2fad

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 Jun 26, 2025

• [FLINK-37687] Introduce support for Flink 2.0 in flink-connector-aws

  hlteoh37

  committed
  373be6f

  Copy full SHA for 373be6f

Commits on Jun 25, 2025

• [FLINK-37866] Migrate glue schema registry e2e test to use aws-kinesis-streams connector

  

  darenwkt

  authored and

  hlteoh37

  committed
  acd6992

  Copy full SHA for acd6992

Commits on May 20, 2025

• [FLINK-36770] make AWS sink writers use ResultHandler, move flink version to 1.20

  

  vahmed-hamdy

  authored and

  hlteoh37

  committed
  d22078f

  Copy full SHA for d22078f

Commits on Apr 15, 2025

• [FLINK-36947][Connectors/Kinesis] Fix issue where excessive GetRecords in PollingKinesisShardSplitReader calls are made on idle source causing throttling

  Show description for 9d6746b
  

  leekeiabstraction

  authored and

  hlteoh37

  committed
  9d6746b

  Copy full SHA for 9d6746b

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 Nov 11, 2024

• [FLINK-36668][build] Update AWS build for v5.0

  hlteoh37

  committed
  b55dec1

  Copy full SHA for b55dec1

Commits on Nov 8, 2024

• [FLINK-31989][docs] Update english docs for Kinesis Table API

  hlteoh37

  committed
  3abc1c5

  Copy full SHA for 3abc1c5

• [FLINK-31989][docs] Update english docs for DynamoDbStreamsSource

  hlteoh37

  committed
  163a475

  Copy full SHA for 163a475

• [FLINK-31989][docs] Update english docs for KinesisStreamsSource

  hlteoh37

  committed
  a2db76b

  Copy full SHA for a2db76b

Commits on Nov 6, 2024

• [hotfix] Update NOTICE files to reflect the packaged dependencies

  hlteoh37

  committed
  e0e1b30

  Copy full SHA for e0e1b30

Commits on Nov 4, 2024

• [FLINK-35401] Add Sqs Table API connector

  

  vahmed-hamdy

  authored and

  hlteoh37

  committed
  c97f93d

  Copy full SHA for c97f93d

• [FLINK-31980][Connectors/Kinesis] Implement EFO subscription

  hlteoh37

  committed
  da74232

  Copy full SHA for da74232

• [FLINK-31980][Connectors/Kinesis] Abstract away base SplitReader logic from PollingKinesisShardSplitReader to set up for FanOutKinesisShardSplitReader

  hlteoh37

  committed
  4f12c86

  Copy full SHA for 4f12c86

Commits on Oct 31, 2024

• [FLINK-36637] Fix ListShards for Kinesis streams with large number of shards

  

  elphastori

  authored and

  hlteoh37

  committed
  30d32fd

  Copy full SHA for 30d32fd

Commits on Oct 30, 2024

• [FLINK-31987][Connectors/AWS] Implement KDS Table API support

  

  karubian

  authored and

  hlteoh37

  committed
  b922a2d

  Copy full SHA for b922a2d

Commits on Oct 24, 2024

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

  

  maoxingda

  authored and

  hlteoh37

  committed
  c057031

  Copy full SHA for c057031

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

  

  gguptp

  authored and

  hlteoh37

  committed
  52870f1

  Copy full SHA for 52870f1

Commits on Oct 14, 2024

• [FLINK-36519][docs] replace accept with apply

  

  Jorick Caberio

  authored and

  hlteoh37

  committed
  6e83eac

  Copy full SHA for 6e83eac

Commits on Oct 11, 2024

• Bump org.apache.avro:avro from 1.11.3 to 1.11.4

  Show description for 426720f
  

  dependabot[bot]

  authored and

  hlteoh37

  committed
  426720f

  Copy full SHA for 426720f

Commits on Oct 7, 2024

• [FLINK-36427] Multiple shard IT cases for KDS source

  

  elphastori

  authored and

  hlteoh37

  committed
  91381cd

  Copy full SHA for 91381cd

Commits on Oct 4, 2024

• [FLINK-31986][Connectors/Kinesis] Setup integration tests for source

  

  elphastori

  authored and

  hlteoh37

  committed
  b681cfc

  Copy full SHA for b681cfc

Commits on Sep 24, 2024

• [FLINK-36357][Connectors/Kinesis] Set up AWS SDK default retry strategy configurations

  hlteoh37

  committed
  7fbca55

  Copy full SHA for 7fbca55

• [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 20, 2024

• Bump com.google.protobuf:protobuf-java from 3.21.7 to 3.25.5

  Show description for 4d4f04b
  

  dependabot[bot]

  authored and

  hlteoh37

  committed
  4d4f04b

  Copy full SHA for 4d4f04b

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 18, 2024

• [FLINK-31922][Connectors/AWS] Port over Kinesis Client configurations for retry and backoff

  

  karubian

  authored and

  hlteoh37

  committed
  22f154b

  Copy full SHA for 22f154b

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 12, 2024

• [FLINK-36138] Add a message to KinesisStreamsSource null checks (#161)

  Show description for 5d2deb1
  kottmann

  authored
  5d2deb1

  Copy full SHA for 5d2deb1

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 5, 2024

• [FLINK-36229][Connectors/AWS] Port SingleThreadMultiplexSourceReaderBase to new undeprecated interfaces

  hlteoh37

  committed
  baef427

  Copy full SHA for baef427

• [FLINK-36187][Connectors/Kinesis] Implement UniformShardAssigner using Kinesis shard hashes in the KinesisStreamsSource

  hlteoh37

  committed
  41f6710

  Copy full SHA for 41f6710

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

Pagination

Previous

Next