All pull requests

Pull requests

• [FLINK-41275][e2e] Start containers in e2e per class rather than per test in SQL e2e

  #29680·snuyanzin opened Oct 30, 2026Contributor·1 task·

  ·

• [BP-2.4][FLINK-40958][core] BinaryVariantInternalBuilder.appendVariantImpl might lead to StackOverflow

  #29679·snuyanzin opened Oct 30, 2026Contributor·

  ·
  1

• [FLINK-41206][python] Log Python worker process exits

  #29678·bgeng777 opened Oct 30, 2026Contributor·1 task done·

  ·
  1

• [FLINK-41271][python] Fail Python tasks when the data RPC terminates

  #29677·bgeng777 opened Oct 29, 2026Contributor·1 task done·

  ·
  1

• [FLINK-41269][runtime] Do not treat task clean-up failure as fatal

  #29676·driessamyn-sparta opened Oct 29, 2026·1 task done·

  ·
  1

• [FLINK-30644][tests] Fix flaky ChangelogCompatibilityITCase

  target:release-1.20
  #29675·spuru9 opened Oct 29, 2026Contributor·1 task done·

  ·
  3

• [FLINK-41210][table] Add StartMode factories for each START_MODE clause

  #29674·Timm0 opened Oct 29, 2026Contributor·1 task done·

  ·
  2

• [BP-2.1][FLINK-41244][table-runtime] Scope clearing of unnamed PTF timers to the current key

  target:release-2.1
  #29673·twalthr opened Oct 29, 2026Contributor·1 task done·

  ·
  2

• [BP-2.2][FLINK-41244][table-runtime] Scope clearing of unnamed PTF timers to the current key

  target:release-2.2
  #29672·twalthr opened Oct 29, 2026Contributor·1 task done·

  ·
  2

• [BP-2.3][FLINK-41244][table-runtime] Scope clearing of unnamed PTF timers to the current key

  target:release-2.3
  #29671·twalthr opened Oct 29, 2026Contributor·1 task done·

  ·
  2

• [FLINK-41265][formats] Add a metric for JSON messages with ignored parse errors.

  #29670·danzhewuju opened Oct 29, 2026Contributor·1 task done·

  ·
  1

• [BP-2.4][FLINK-41244][table-runtime] Scope clearing of unnamed PTF timers to the current key

  target:release-2.4
  #29669·twalthr opened Oct 29, 2026Contributor·1 task done·

  ·
  2

• Bump io.opentelemetry:opentelemetry-api from 1.62.0 to 1.67.0 in /flink-python

  dependenciesjava
  #29668·dependabot[bot] opened Oct 29, 2026Bot·

  ·
  1

• [FLINK-41260][table] Reject ORDER BY in ARRAY_AGG

  #29667·rionmonster opened Oct 29, 2026Contributor·1 task done·

  ·
  2

• [FLINK-41200][table-planner] Consider non-equi conditions in unique groups of outer joins

  #29666·yusufyildiz34 opened Oct 29, 2026·1 task done·

  ·
  1

• [FLINK-41037][table-planner] Fix unique groups of the null-padded side of an outer join

  #29665·yusufyildiz34 opened Oct 29, 2026·1 task done·

  ·
  1

• [FLINK-40928][table-planner] Fix pushing aggregates without grouping keys through joins

  #29664·yusufyildiz34 opened Oct 29, 2026·1 task done·

  ·
  1

• [DRAFT][ci] Use maven cache in Azure

  #29663·snuyanzin opened Oct 28, 2026Contributor·1 task·

  ·
  1

• [FLINK-38770][runtime] Apply jobvertex parallelism overrides to StreamGraph submissions

  #29662·MartijnVisser opened Oct 28, 2026Contributor·1 task done·

  ·
  1

• [FLINK-41211][table] Add listMaterializedTables for a given catalog and database

  #29661·Timm0 opened Oct 28, 2026Contributor·1 task done·

  ·
  5

• [FLINK-41247][queryable-state] Close server channels before shutting down the Netty event loops

  #29660·spuru9 opened Oct 28, 2026Contributor·1 task done·

  ·
  5

  

• [FLINK-41209][table] Run materialized table jobs in any TableEnvironment

  #29659·Timm0 opened Oct 28, 2026Contributor·1 task done·

  ·
  1

  

• [FLINK-41256][runtime] Fail on operators changing the current key out of order in BATCH execution

  community-reviewedcommunity-reviewed-LGTM
  #29658·pnowojski opened Oct 28, 2026Contributor·1 task done·

  ·
  14

• [FLINK-38753] [table-planner] Enrich upsert keys by equi-join equivalences

  community-reviewed
  #29653·fresh-borzoni opened Oct 28, 2026Member·1 task done·

  ·
  9

• [FLINK-41253][python] Preserve scalar projection order when using async UDFs

  #29652·auroflow opened Oct 28, 2026Contributor·1 task done·

  ·
  1