All pull requests

Pull requests

• [FLINK-40750][Connectors/AWS] Add AI disclosure to the PR template

  component=BuildSystem
  #256·Savonitar opened Sep 22, 2026·

  ·
  1

  

• [FLINK-37908][Connectors/Kinesis] Self-heal EFO consumer on restart races and external deletion

  #255·aqibmehmoodDH opened Aug 19, 2026·

  ·
  5

• [FLINK-39813][Connectors/Kinesis] Add lineage support to Kinesis Streams connector

  #250·fmorillo7694 opened Jun 1, 2026·

  ·
  1

• [FLINK-39810][Connectors/kinesis] Support upsert changelog streams in Kinesis SQL connector

  component=Documentation
  #249·fmorillo7694 opened Jun 1, 2026·

  ·

• [FLINK-39599][Connectors/Kinesis] Emit pendingRecords metric in Kinesis connector.

  #246·dwangatt opened May 4, 2026·

  ·
  1

• [FLINK-39540][Connectors/Kinesis][5.1] Addressed bugs for EFO subscriptions when they are completed

  #245·pelaezryan opened Apr 29, 2026Contributor·

  ·
  8

• [FLINK-39098] Bump testcontainers to 1.21.4 for Docker API compatibility

  #242·shivaam opened Apr 2, 2026·

  ·
  3

• [FLINK-31942][Connectors/DynamoDB] Added support for conditional writ…

  #240·losmotylos opened Mar 28, 2026·

  ·
  1

• [FLINK-24379] Add Glue Schema Registry SQL formats: Avro, Protobuf, JSON

  component=Documentation
  #236·fmorillo7694 opened Feb 23, 2026·

  ·
  2

• [hotfix] Update CI Flink versions and test released versions in scheduled CI

  component=BuildSystem
  #233·ferenc-csaky opened Feb 16, 2026Contributor·

  ·

• [FLINK-39098] Bump testcontainers to 1.21.4 for Docker API compatibility

  component=BuildSystem
  #232·ferenc-csaky opened Feb 16, 2026Contributor·

  ·

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

  dependenciesjava
  #231·dependabot[bot] opened Feb 13, 2026Bot·

  ·

• Bump org.assertj:assertj-core from 3.21.0 to 3.27.7

  dependenciesjava
  #230·dependabot[bot] opened Jan 26, 2026Bot·

  ·

• [FLINK-38814][Connector/Kinesis] Kinesis Source in EFO - Fix idle consumer on subscription failure

  #224·nadberezny opened Dec 17, 2025·

  ·
  8

• [FLINK-37968][Connectors/Kinesis] Update netty version to v4.1.127.Final

  #221·Neo2308 opened Sep 17, 2025·

  ·
  2

• [FLINK-36359][Connectors/DynamoDB] IT Case for DDB Streams connector

  #220·karanmakhija867 opened Aug 5, 2025·

  ·
  1

• Bump org.apache.commons:commons-lang3 from 3.12.0 to 3.18.0

  dependenciesjava
  #217·dependabot[bot] opened Jul 12, 2025Bot·

  ·

• [hotfix][build] Update Python CI Java version to fix CI

  component=BuildSystem
  #216·hlteoh37 opened Jun 26, 2025Contributor·

  ·

• FLINK-37949: Avoid netty deadlock with graceful shutdown

  #215·jayteej opened Jun 16, 2025·

  ·
  5

• [FLINK-37908] Resolve EFO-enabled KinesisStreamsSource initialization failure on automated restarts

  component=Documentation
  #213·digitalpoetry opened Jun 6, 2025·

  ·
  6

• [FLINK-34071][Connectors/Kinesis] Decouple NettyEventLoop thread's onNext() by handing over blocking queue put to a separate executor. Using a shared executor across shards to execute processing of event received by NettyEventLoop.

  #208·aws-nageshvh opened May 16, 2025·

  ·
  23

• [FLINK-29549]- Flink Glue Catalog integration

  component=Documentation
  #206·fmorillo7694 opened May 7, 2025·

  ·
  48

• [FLINK-37688] Implement Amazon CloudWatch Metric Sink Connector

  #202·darenwkt opened Apr 21, 2025Contributor·

  ·
  30

• [FLINK-35989][Connectors/AWS] Log errors on partially failed requests for AWS Kinesis Stream sink

  #201·aws-nageshvh opened Apr 16, 2025·

  ·
  12

• [FLINK-37683][Connectors/AWS] Enable SSO credentials

  component=BuildSystem
  #197·soisyourface opened Apr 9, 2025·

  ·
  8