All pull requests

Pull requests

• [FLINK-33186][tests] Disable periodic checkpoints in the restored job of CheckpointAfterAllTasksFinishedITCase

  #29517·Efrat19 opened Oct 18, 2026Contributor·1 task done·

  ·
  1

• [FLINK-41020][python][docs] Update PyFlink docs dependencies with open Dependabot advisories

  #29516·MartijnVisser opened Oct 18, 2026Contributor·1 task done·

  ·
  1

• [FLINK-41022][build] Update lz4-java to 1.12.0

  #29515·MartijnVisser opened Oct 18, 2026Contributor·1 task done·

  ·
  1

• [FLINK-41021][build] Update commons-beanutils to 1.11.0 and jsoup to 1.23.2

  #29514·MartijnVisser opened Oct 18, 2026Contributor·1 task done·

  ·
  1

• [FLINK-40192][python] Add as-of join support to DataFrame API

  #29513·beetle0915 opened Oct 18, 2026Contributor·1 task done·

  ·
  1

• [WIP][FLINK-XXXXX][Table SQL/API] Introduce CBRT as a built-in function for SQL and Table API

  #29512·RocMarshal opened Oct 18, 2026Contributor·1 task·

  ·
  3

• Bump org.jsoup:jsoup from 1.15.3 to 1.23.2 in /flink-docs

  dependenciesjava
  #29511·dependabot[bot] opened Oct 18, 2026Bot·

  ·
  1

• [FLINK-41019][table-planner] Record table.exec.sink.nested-constraint-enforcer in the compiled plan

  #29510·SEPURI-SAI-KRISHNA opened Oct 18, 2026Contributor·1 task done·

  ·
  5

• [FLINK-32040][python] Preserve timestamp assigners in enriched watermark strategies

  #29509·bgeng777 opened Oct 18, 2026Contributor·1 task done·

  ·
  2

• [FLINK-41018][Table SQL/API] Introduce BIT_COUNT as a built-in function for SQL and Table API

  #29508·RocMarshal opened Oct 18, 2026Contributor·1 task·

  ·
  2

• [FLINK-40463][table] Widen JSON_VALUE and JSON_QUERY RETURNING type support

  #29506·snuyanzin opened Oct 17, 2026Contributor·1 task·

  ·
  11

• [FLINK-38500][python] Bump pemja to 0.5.8

  target:release-1.20
  #29505·sangkyoonnam opened Oct 17, 2026·1 task done·

  ·
  1

• [FLINK-38500][python] Bump pemja to 0.5.8

  target:release-2.2
  #29504·sangkyoonnam opened Oct 17, 2026·1 task done·

  ·
  1

• [FLINK-38500][python] Bump pemja to 0.5.8

  target:release-2.3
  #29503·sangkyoonnam opened Oct 17, 2026·1 task done·

  ·
  1

• [FLINK-38500][python] Bump pemja to 0.6.3

  #29502·sangkyoonnam opened Oct 17, 2026·1 task done·

  ·
  4

• [FLINK-41014][s3] Add an adaptive retry mode to the native S3 connector

  #29499·gaborgsomogyi opened Oct 16, 2026Contributor·1 task done·

  ·
  1

• [FLINK-40609][python] Infer ROW types from dataclass, NamedTuple and tuple type hints

  #29498·autophagy opened Oct 16, 2026Contributor·1 task done·

  ·
  1

• [FLINK-40963][table-planner] Add support for DATE and TIME conversion to JSON

  #29493·kurnoolsaketh opened Oct 15, 2026·2 tasks done·

  ·
  4

• [FLINK-40962][table-planner] expose LEAD(TIMESTAMP_LTZ)/LAG(TIMESTAMP_LTZ) in batch mode

  #29492·kurnoolsaketh opened Oct 15, 2026·1 of 2 tasks·

  ·
  2

• [FLINK-40924][table-planner] Enforce require-on-conflict under upsert-materialize FORCE

  #29491·SEPURI-SAI-KRISHNA opened Oct 15, 2026Contributor·1 task done·

  ·
  1

• [FLINK-40817][yarn] Remove the deprecated configuration keys from the flink-yarn module.

  #29489·RocMarshal opened Oct 15, 2026Contributor·1 task·

  ·
  2

• [FLINK-38783][runtime] Make TieredStorageResourceRegistry thread-safe

  #29488·abjfh30 opened Oct 15, 2026·1 task done·

  ·
  1

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

  #29484·mateczagany opened Oct 14, 2026Contributor·1 task done·

  ·
  1

• [FLINK-40995][ci] Exclude draft pull requests from the community review scan

  #29482·SEPURI-SAI-KRISHNA opened Oct 14, 2026Contributor·1 task done·

  ·
  3

• [FLINK-40988][tests] Bump JUnit to 5.14.4

  #29476·MartijnVisser opened Oct 13, 2026Contributor·1 task done·

  ·
  2