All pull requests

Pull requests

• [FLINK-40476][docs] Clarify Changelog state backend requires CLAIM restore mode

  community-reviewed
  #29025·vsantwana opened Aug 26, 2026Contributor·

  ·
  3

• [FLINK-40450][table-planner] Add missing flink-table-code-splitter test dependency

  community-reviewed
  #29019·shoemoney opened Aug 25, 2026·

  ·
  3

• [FLINK-39617] [runtime] Add batch aggregated subtask metrics endpoints

  #29012·Jackeyzhe opened Aug 24, 2026Contributor·1 task done·

  ·
  2

• [FLINK-37155][historyserver] Decouple remote archive retention from local processing limit

  community-reviewed
  #29008·argoyal2212 opened Aug 24, 2026Contributor·

  ·
  6

• [FLINK-40294][table-planner] Instrument async scalar and table UDF calls with metrics

  community-reviewed
  #29007·weiqingy opened Aug 24, 2026Contributor·1 task done·

  ·
  6

• [FLINK-40379][runtime] Wait for pre-restart parallelism to become available again after a rescale-triggered restart

  #28999·akalash opened Aug 20, 2026Contributor·1 task done·

  ·
  21

• [FLINK-40728][k8s][build] Migrate Flink off end-of-life OkHttp and keep it off the core classpath (FLIP-607)

  community-reviewed
  #28995·MartijnVisser opened Aug 20, 2026Contributor·1 task done·

  ·
  10

• [FLINK-40444][table-common] Preserve attribute order in OBJECT_UPDATE

  #28994·SEPURI-SAI-KRISHNA opened Aug 19, 2026Contributor·1 task done·

  ·
  9

• [FLINK-40344][table] Support selecting computed grouping expressions

  #28987·beetle0915 opened Aug 18, 2026Contributor·1 task done·

  ·
  6

• [FLINK-40403][runtime] Pre-compile subtask-index regexes in MetricStore

  community-reviewed-LGTM
  #28986·NeQuissimus opened Aug 17, 2026·1 task done·

  ·
  3

• [FLINK-40327][state/forst] Close ReadOptions in ForStGeneralMultiGetOperation to fix native memory leak

  #28985·YordanPavlov opened Aug 17, 2026·

  ·
  5

• [FLINK-40001][table] Upgrade Calcite version to 1.42.0

  #28981·snuyanzin opened Aug 16, 2026Contributor·1 task·

  ·
  4

• [FLINK-40368][table-planner] Fix deduplication changelog inference

  #28980·ltyfulan9 opened Aug 15, 2026·1 task done·

  ·
  5

• [FLINK-40196][python] Add missing-value handling to DataFrame API

  #28979·MattBelle opened Aug 14, 2026·1 task done·

  ·
  24

• [FLINK-40716][FLIP-597][filesystem] Add common object storage stream abstractions

  #28976·Izeren opened Aug 14, 2026Contributor·1 task done·

  ·
  3

  

• [FLINK-40298][table] Opt-in name-based state schema evolution for RowData

  #28973·weiqingy opened Aug 14, 2026Contributor·1 task done·

  ·
  2

• [FLINK-40212][docs] Add Regional Checkpoint user documentation

  #28966·raoraoxiong opened Aug 13, 2026Contributor·

  ·
  2

• [FLINK-40211][checkpoint] Add Regional Checkpoint metrics, REST API and Web UI support

  #28965·raoraoxiong opened Aug 13, 2026Contributor·

  ·
  1

• [FLINK-40210][checkpoint] Add Per-Region timeout handling and bounded source forced global checkpoint

  #28964·raoraoxiong opened Aug 13, 2026Contributor·

  ·
  1

• [FLINK-40209][checkpoint] Introduce Regional Checkpoint core mechanism and notification dispatch

  community-reviewed
  #28963·raoraoxiong opened Aug 13, 2026Contributor·

  ·
  5

• [draft] Monotonic counters draft

  #28956·Efrat19 opened Aug 11, 2026Contributor·1 task·

  ·
  1

• [FLINK-40358][s3][tests] Use native S3 filesystem for all S3 end-to-end tests

  #28946·Samrat002 opened Aug 9, 2026Contributor·1 task·

  ·
  3

  

• [FLINK-40357][table] Add ARRAY_FLATTEN function to Flink SQL

  #28945·cytq-123 opened Aug 9, 2026·

  ·
  4

• Bump hono from 4.12.27 to 4.13.1 in /flink-runtime-web/web-dashboard

  dependenciesjavascript
  #28944·dependabot[bot] opened Aug 8, 2026Bot·

  ·
  1

• [FLINK-29775][tests][JUnit5 migration] Module: flink-statebackend-rocksdb

  community-reviewed
  #28943·spuru9 opened Aug 7, 2026Contributor·1 task done·

  ·
  9