All pull requests

Pull requests

• [hotfix][ci] Use native git in ci

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

  ·
  1

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

  #29700·spuru9 opened Oct 30, 2026Contributor·1 task done·

  ·
  1

  

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

  #29699·spuru9 opened Oct 30, 2026Contributor·1 task done·

  ·
  1

  

• [FLINK-41273][table] Support set operations on unbounded tables in the Table API

  #29698·Timm0 opened Oct 30, 2026Contributor·1 task done·

  ·
  1

• [FLINK-41282][table-planner] Use each multi-join step's own join colu…

  #29697·fresh-borzoni opened Oct 30, 2026Member·

  ·
  1

• [Backport][FLINK-40842][table] Handle upsert inputs in the streaming semi/anti join (release-2.2)

  target:release-2.2
  #29696·rionmonster opened Oct 30, 2026Contributor·

  ·
  1

• [Backport][FLINK-40842][table] Handle upsert inputs in the streaming semi/anti join (release-2.3)

  target:release-2.3
  #29695·rionmonster opened Oct 30, 2026Contributor·

  ·
  1

• [Backport][FLINK-40842][table] Handle upsert inputs in the streaming semi/anti join (release-2.4)

  target:release-2.4
  #29694·rionmonster opened Oct 30, 2026Contributor·

  ·
  1

• [hotfix][runtime] Fix typo in JobManagerProcessSpec and TaskExecutorP…

  community-reviewed
  #29691·garvitlnmiit opened Oct 30, 2026·1 task·

  ·
  1

  

• [FLINK-41281][table] Allow CAST from a VARIANT timestamp to the other temporal types

  #29690·raminqaf opened Oct 30, 2026Contributor·1 task done·

  ·
  1

• [FLINK-41280][table] Fix CAST of a TIMESTAMP before 1970 to DATE, TIME and a lower precision

  community-reviewed
  #29689·raminqaf opened Oct 30, 2026Contributor·1 task done·

  ·
  3

• [FLINK-41279][table] Support the :: infix cast operator

  #29688·raminqaf opened Oct 30, 2026Contributor·1 task done·

  ·
  1

• [FLINK-41278][table] Distinguish DEFAULT arguments from explicit NULL during type inference

  #29684·dylanhz opened Oct 30, 2026Contributor·1 task done·

  ·
  1

• [FLINK-41277][tests] test_file_sink.sh hangs in the second OpenSSL linkage run

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

  ·
  2

• [FLINK-41045][e2e] Increase slot request timeout in Kerberized YARN Docker tests

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

  ·
  1

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

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

  ·
  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·

  ·
  8

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

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

  ·
  6

  

• [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