All pull requests

Pull requests

• [FLINK-38562][python] Support async functions in thread mode

  #29635·sangkyoonnam opened Oct 27, 2026Contributor·1 task done·

  ·
  1

• [BP-1.20][FLINK-41049][ci] Make pre-downloaded Maven usable by the only-script Maven wrapper

  target:release-1.20
  #29633·snuyanzin opened Oct 27, 2026Contributor·

  ·
  1

• [BP-2.2][FLINK-41049][ci] Make pre-downloaded Maven usable by the only-script Maven wrapper

  target:release-2.2
  #29632·snuyanzin opened Oct 27, 2026Contributor·

  ·
  1

• [BP-2.3][FLINK-41049][ci] Make pre-downloaded Maven usable by the only-script Maven wrapper

  target:release-2.3
  #29631·snuyanzin opened Oct 27, 2026Contributor·

  ·
  1

• [FLINK-41228][python] Fix thread-mode conversion of arrays, lists and maps

  #29630·sangkyoonnam opened Oct 27, 2026Contributor·1 task done·

  ·
  1

• [FLINK-41086][table] Return NULL from JSON_LENGTH and JSON_TYPE when a JSON path function fails

  #29628·ykisana opened Oct 27, 2026Contributor·1 task done·

  ·
  4

• [flink-xxx][runtime] support dynamic rate limit source (PoC)

  #29627·HuangZhenQiu opened Oct 26, 2026Member·

  ·
  1

• [hotfix][ci] Use blobless fetch in Azure single-branch checkout

  #29625·snuyanzin opened Oct 26, 2026Contributor·1 task·

  ·
  1

• [FLINK-41217][table] VALUES source emits its rows again when a streaming job restores from a checkpoint taken before the source exits

  community-reviewed
  #29624·hanyuzheng7 opened Oct 26, 2026Contributor·

  ·
  2

• [BP-1.20][FLINK-41090][runtime] Close the operator coordinators of uninitialized vertices on dispose

  target:release-1.20
  #29623·uvashishtha opened Oct 26, 2026·1 task done·

  ·
  1

• [BP-2.4][FLINK-41180][core] Sort VARIANT object fields by UTF-8 bytes

  target:release-2.4
  #29622·raminqaf opened Oct 26, 2026Contributor·1 task done·

  ·
  1

  

• [BP-2.2][FLINK-41090][runtime] Close the operator coordinators of uninitialized vertices on dispose

  target:release-2.2
  #29621·uvashishtha opened Oct 26, 2026·1 task done·

  ·
  1

• [BP-2.3][FLINK-41090][runtime] Close the operator coordinators of uninitialized vertices on dispose

  target:release-2.3
  #29620·uvashishtha opened Oct 26, 2026·1 task done·

  ·
  1

• [BP-2.4][FLINK-41090][runtime] Close the operator coordinators of uninitialized vertices on dispose

  target:release-2.4
  #29619·uvashishtha opened Oct 26, 2026·1 task done·

  ·
  1

• [FLINK-40123][e2e] heck_logs_for_exceptions false-positives on S3A stream_write_exceptions counter, flaking test_kubernetes_materialized_table.sh

  #29618·mbarnacki opened Oct 26, 2026·1 task done·

  ·
  1

• [FLINK-39049][table] Add VARIANT_GET and TRY_VARIANT_GET

  #29617·raminqaf opened Oct 26, 2026Contributor·1 task done·

  ·
  2

• [FLINK-40812][state] Backport FLINK-38558 to release-1.20

  target:release-1.20
  #29615·yangjunsen opened Oct 26, 2026·1 task done·

  ·
  1

• [FLINK-41039][table-planner] Only push projections into the inputs of UNION ALL

  #29614·manish1337 opened Oct 26, 2026·1 task done·

  ·
  1

• [BP-1.20][FLINK-40997][table-planner] Fix join upsert key order being non-deterministic

  target:release-1.20
  #29613·mateczagany opened Oct 26, 2026Contributor·

  ·
  1

• [BP-2.2][FLINK-40997][table-planner] Fix join upsert key order being non-deterministic

  target:release-2.2
  #29612·mateczagany opened Oct 26, 2026Contributor·

  ·
  1

• [BP-2.3][FLINK-40997][table-planner] Fix join upsert key order being non-deterministic

  target:release-2.3
  #29611·mateczagany opened Oct 26, 2026Contributor·

  ·
  1

• [FLINK-41202][docs] Make connector integrations easier to find from the Flink docs

  community-reviewed
  #29609·MartijnVisser opened Oct 26, 2026Contributor·1 task done·

  ·
  3

• [FLINK-41108][python] Use the TTL config when invalidating cached state after namespace merges

  #29602·sangkyoonnam opened Oct 26, 2026Contributor·1 task done·

  ·
  1

• [FLINK-41103][python] Clear ValueState without adding None in update(None)

  #29601·sangkyoonnam opened Oct 26, 2026Contributor·1 task done·

  ·
  1

• [FLINK-41102][python] Flush pending keyed state operations on key switch without state cache

  #29600·sangkyoonnam opened Oct 26, 2026Contributor·1 task done·

  ·
  1