All pull requests

Pull requests

• [BP-2.3][FLINK-40109][yarn][tests] Include rolled logs in the keytab log check

  #29340·MartijnVisser opened Sep 29, 2026Contributor·

  ·
  1

• [FLINK-40841][table] Non-equi joins fix: retract the matches that a replaced record loses

  #29339·gustavodemorais opened Sep 29, 2026Contributor·

  ·
  1

• [BP-2.2][FLINK-39103][runtime] Tolerate errors when recycling buffer from input channel notification if it had errors already

  target:release-2.2
  #29338·MartijnVisser opened Sep 29, 2026Contributor·

  ·
  1

• [BP-2.2][FLINK-40682][tests] Fix unstable ArchivedExecutionGraphTest and CachedShuffleDescriptorsTest

  target:release-2.2
  #29337·SEPURI-SAI-KRISHNA opened Sep 29, 2026Contributor·

  ·
  1

• [BP-2.3][FLINK-40682][tests] Fix unstable ArchivedExecutionGraphTest and CachedShuffleDescriptorsTest

  target:release-2.3
  #29336·SEPURI-SAI-KRISHNA opened Sep 29, 2026Contributor·

  ·
  1

• [FLINK-40844][table] Only EXPR$0 when a PTF's whole output is empty

  #29335·VasShabu opened Sep 29, 2026Contributor·

  ·
  2

• [FLINK-24908][sql-client] Print the outermost exception that ends with the root cause

  #29334·MartijnVisser opened Sep 29, 2026Contributor·

  ·
  1

• [FLINK-24908][table-planner] Include the parser position in SqlParserException messages

  #29333·MartijnVisser opened Sep 29, 2026Contributor·

  ·
  1

• [BP-2.2][FLINK-40504][runtime] Re-activate idle FLIP-27 outputs when they resume

  target:release-2.2
  #29332·Admaing opened Sep 29, 2026Contributor·

  ·
  1

• [BP-2.3][FLINK-40504][runtime] Re-activate idle FLIP-27 outputs when they resume

  target:release-2.3
  #29331·Admaing opened Sep 29, 2026Contributor·

  ·
  1

• [FLINK-40839][table] Support VARIANT columns omitted from an INSERT column list

  #29330·raminqaf opened Sep 28, 2026Contributor·

  ·
  7

• [FLINK-32451][tests] Rewrite the Confluent Schema Registry e2e test without the Kafka connector

  #29329·MartijnVisser opened Sep 28, 2026Contributor·

  ·
  1

• [FLINK-40834][ci] Keep rolled YARN container logs in CI artifacts

  community-reviewed
  #29328·MartijnVisser opened Sep 28, 2026Contributor·

  ·
  1

• [FLINK-40604][datastream] Route expired async retry results through timeout handler

  #29327·dpeacock opened Sep 28, 2026·

  ·
  1

• [FLINK-40832][core] Validate decimal range in VariantBuilder.of(BigDecimal)

  community-reviewed
  #29323·manner opened Sep 28, 2026Contributor·

  ·
  8

• [FLINK-38534][runtime/tests] Wait for task triggers in LocalRecoveryTest

  #29322·MartijnVisser opened Sep 28, 2026Contributor·

  ·
  1

• [FLINK-40830][table] Reuse java's getBytes in StringUtf8Bytes

  #29313·snuyanzin opened Sep 28, 2026Contributor·

  ·
  8

• [FLINK-40829][python] Allow assign uid for Timestamp operators

  #29312·florianvazelle opened Sep 28, 2026Contributor·

  ·
  1

• [FLINK-40825][table] Support casting primitive types to VARIANT

  #29311·raminqaf opened Sep 28, 2026Contributor·

  ·
  1

• [FLINK-40396][connector-base] Create split readers on the split fetcher thread

  #29308·Zhuoxi2000 opened Sep 28, 2026·

  ·
  5

• [FLINK-40670][tests] Make Semantic tests tolerant to concurrent runs

  #29307·snuyanzin opened Sep 27, 2026Contributor·

  ·
  4

• [FLINK-40678][table] Include the scan's hints in the lookup join digest

  #29306·CodeTrainerMan opened Sep 27, 2026·

  ·
  1

• [FLINK-32806][runtime] Support eviction of clean job result entries in EmbeddedJobResultStore

  #29304·CodeTrainerMan opened Sep 27, 2026·

  ·
  1

• [FLINK-40425][python][table] Support OVER windows in DataFrame API

  #29303·bladedragon opened Sep 27, 2026·

  ·
  1

• [FLINK-34427][runtime] Pending tasks should be canceled if slot manager is closed

  community-reviewed
  #29301·snuyanzin opened Sep 26, 2026Contributor·

  ·
  7