All pull requests

Pull requests

• [FLINK-41196][python] Preserve TIMESTAMP_LTZ instants in pandas conversions

  #29603·bgeng777 opened Oct 26, 2026Contributor·1 task done·

  ·
  1

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

• [FLINK-41104][python] Return true from MapState.contains for keys mapped to None

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

  ·
  1

• [FLINK-XXXXX][s3] Report a zero-length object as a file in NativeS3FileSystem.getFileStatus

  #29598·liuzix opened Oct 26, 2026·1 task done·

  ·
  1

• [FLINK-41106][python] Iterate key-value pairs in MapState.put_all

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

  ·
  1

• [FLINK-41193][checkpointing] Disable checkpointing during recovery when aligned-checkpoint-timeout > 0

  #29596·1996fanrui opened Oct 25, 2026Member·1 task done·

  ·
  3

• [FLINK-33186][tests][BP-2.3] Addressing CheckpointAfterAllTasksFinishedITCase CI flakiness

  target:release-2.3
  #29592·Efrat19 opened Oct 25, 2026Contributor·

  ·
  1

• Bump undici and @angular/build in /flink-runtime-web/web-dashboard

  dependenciesjavascript
  #29591·dependabot[bot] opened Oct 24, 2026Bot·

  ·
  1

• Bump fast-uri from 3.1.8 to 3.1.9 in /flink-runtime-web/web-dashboard

  dependenciesjavascript
  #29590·dependabot[bot] opened Oct 24, 2026Bot·

  ·
  1

• [FLINK-40846][tests] Remove the REQUIREMENTS_CHECK_DELAY override from EventTimeWindowCheckpointingITCase

  #29589·ykisana opened Oct 24, 2026Contributor·1 task·

  ·
  1

• [FLINK-41117][ci] Bump ubuntu to 26 in Azure and GHA

  community-reviewed
  #29588·snuyanzin opened Oct 24, 2026Contributor·1 task·

  ·
  1

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

  #29587·snuyanzin opened Oct 24, 2026Contributor·1 task·

  ·
  2

• [FLINK-41118][tests] Migrate EventTimeWindowCheckpointingITCase to Source V2 and remove FailingSource

  #29586·MartijnVisser opened Oct 24, 2026Contributor·1 task done·

  ·
  2

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

  #29585·uvashishtha opened Oct 23, 2026·1 task done·

  ·
  1

• [FLINK-41115][runtime] Isolate adaptive graph recovery from IO

  #29584·dpeacock opened Oct 23, 2026·1 task done·

  ·
  1

• [FLINK-41066][table] Handle upsert inputs in multi-way joins

  #29583·rionmonster opened Oct 23, 2026Contributor·1 task done·

  ·
  1

• [FLINK-41114][docs] Document uid argument for FROM_CHANGELOG and TO_CHANGELOG

  #29582·gustavodemorais opened Oct 23, 2026Contributor·1 task done·

  ·
  1

• docs: remove stray brace in README streaming example

  #29581·pei711 opened Oct 23, 2026·

  ·
  1

• [FLINK-41110][core] Compare UTF-8 bytes to find VARIANT object fields

  #29580·raminqaf opened Oct 23, 2026Contributor·1 task done·

  ·
  2

• [FLINK-40655][tests] Run deployment callbacks inline in ExecutionVertexTest

  #29577·SEPURI-SAI-KRISHNA opened Oct 23, 2026Contributor·1 task done·

  ·
  1

• [FLINK-34625][python] Fix state TTL read cache disabling

  #29576·w-yfan opened Oct 23, 2026·

  ·
  5

• [FLINK-41095][runtime/state] Honor null removals in MapStateAdaptor

  community-reviewed
  #29575·minxhe opened Oct 22, 2026·1 task done·

  ·
  2

• [FLINK-41094][state/forst] Fail async map access on iterator errors and close iterators by owner only

  community-reviewed
  #29574·minxhe opened Oct 22, 2026·1 task done·

  ·
  6